Merge pull request #23 from Fohn-Group/improve-buffer-handling-sse

improve buffer size handling for SSE

src/App.php

@@ -170,10 +170,10 @@ public function isConnectionAborted(): int
     /**
      * Output Server side event to client.
      */
-    public function streamEvent(array $event): void
+    public function streamEvent(array $event, int $bufferSize = 0): void
     {
         foreach ($event as $v) {
-            echo $v;
+            echo $v .= ': ' . str_pad('x', $bufferSize) . "\n\n";
         }
 
         flush();

src/Callback/ServerEvent.php

@@ -39,8 +39,8 @@ class ServerEvent extends Generic
     public bool $keepAlive = false;
 
     /**
-     * The min size of event stream data to be output.
-     * Set it to 4096 when using phpfpm.
+     * The min size of event stream data buffer.
+     * Set it to 4096 when using phpfpm with apache mod_proxy_fcgi.
      */
     public int $minBufferSize = 0;
 
@@ -133,10 +133,10 @@ protected function sendBlock(string $id, string $event, string $name): void
         $streamEvent = [
             'id: ' . $id . "\n",
             'event: ' . $name . "\n",
-            'data' => $this->wrapEvent(str_pad($event, $this->minBufferSize)) . "\n",
+            'data' => $this->wrapEvent($event) . "\n",
         ];
 
-        $this->app->streamEvent($streamEvent);
+        $this->app->streamEvent($streamEvent, $this->minBufferSize);
     }
 
     public function start(JsStatements $statements = null): JsRenderInterface

tests/Callback/MockApp.php

@@ -19,7 +19,7 @@ public function callExit(): void
     {
     }
 
-    public function streamEvent(array $event): void
+    public function streamEvent(array $event, int $bufferSize = 0): void
     {
     }
 }