fix: events duplication

gosuperscript · Jul 31, 2019 · 795c035 · 795c035
1 parent 7ce435b
commit 795c035
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)