Merge pull request #2 from DeepDiver1975/bugfix/1

Detect connection abort
hhxsv5 · Jun 22, 2018 · f0d1eac · f0d1eac
2 parents 49ece5f + 26f3645
commit f0d1eac
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/src/SSE.php b/src/SSE.php
@@ -10,7 +10,7 @@ public function start(Update $update, $eventType = null)
             $changedData = $update->getUpdatedData();
             if ($changedData !== false) {
                 $event = [
-                    'id'    => uniqid(),
+                    'id'    => uniqid('', true),
                     'type'  => $eventType,
                     'data'  => (string)$changedData,
                     'retry' => 2000,//reconnect after 2s
@@ -23,6 +23,10 @@ public function start(Update $update, $eventType = null)
             echo new Event($event);
             ob_flush();
             flush();
+            // if the connection has been closed by the client we better exit the loop
+            if (connection_aborted()) {
+                return;
+            }
             sleep($update->getCheckInterval());
         }
     }