Merge pull request #5 from eithed/fix-events-duplication

fix: events duplication
gosuperscript · Jul 31, 2019 · 29b67eb · 29b67eb
2 parents 7ce435b + 795c035
commit 29b67eb
Showing 1 changed file with 7 additions and 6 deletions.
diff --git a/src/EventStoreWorker.php b/src/EventStoreWorker.php
@@ -48,15 +48,16 @@ public function handle()
 
     public function processAllStreams()
     {
-        $eventStore = new EventStore();
-        $connection = $eventStore->connect(config('eventstore.tcp_url'));
         $streams = config('eventstore.streams');
 
-        $connection->subscribe(function () use ($eventStore, $streams) {
-            foreach ($streams as $stream) {
+        foreach ($streams as $stream) {
+            $eventStore = new EventStore();
+            $connection = $eventStore->connect(config('eventstore.tcp_url'));
+
+            $connection->subscribe(function () use ($eventStore, $stream) {
                 $this->processStream($eventStore, $stream);
-            }
-        }, 'report');
+            }, 'report');
+        }
     }
 
     private function processStream($eventStore, string $stream)