Update FirehoseServeCommand.php

kawax · Dec 15, 2024 · 251bc0c · 251bc0c
1 parent 7de6b7e
commit 251bc0c
Showing 1 changed file with 1 addition and 5 deletions.
diff --git a/src/Console/FirehoseServeCommand.php b/src/Console/FirehoseServeCommand.php
@@ -68,12 +68,9 @@ public function handle(): int
 
         $this->info('Host : '.$host);
 
-        $event = null;
-
         while (! $ws->eof() || $this->running) {
-            $event .= $ws->read();
+            $event = $ws->read();
 
-            // Firehose often receives incorrect data.
             $header = rescue(fn () => CBOR::decode($event));
             if (blank($header) || ! $header instanceof MapObject) {
                 if ($this->output->isVerbose()) {
@@ -109,7 +106,6 @@ public function handle(): int
 
             if (Arr::has($header, ['t']) && is_array($payload)) {
                 event(new FirehoseMessageReceived($header, $payload, $roots, $blocks, $host, $event));
-                $event = null;
             }
         }