Consider to flush buffer after a record has been processed (#62)

* Consider to flush buffer after a record has been processed * Fix syntax
maxbanton · May 21, 2019 · 4ee243d · 4ee243d
1 parent fc9b602
commit 4ee243d
Showing 1 changed file with 7 additions and 6 deletions.
diff --git a/src/Handler/CloudWatch.php b/src/Handler/CloudWatch.php
@@ -143,13 +143,14 @@ protected function write(array $record)
         $records = $this->formatRecords($record);
 
         foreach ($records as $record) {
-            if ($this->currentDataAmount + $this->getMessageSize($record) >= $this->dataAmountLimit ||
-                count($this->buffer) >= $this->batchSize
-            ) {
+            if ($this->currentDataAmount + $this->getMessageSize($record) >= $this->dataAmountLimit) {
+                $this->flushBuffer();
+            }
+
+            $this->addToBuffer($record);
+
+            if (count($this->buffer) >= $this->batchSize) {
                 $this->flushBuffer();
-                $this->addToBuffer($record);
-            } else {
-                $this->addToBuffer($record);
             }
         }
     }