shutdown with the first error

hsldymq · Mar 28, 2019 · d89a76a · d89a76a
1 parent 32105c3
commit d89a76a
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/src/Dispatcher.php b/src/Dispatcher.php
@@ -229,9 +229,12 @@ public function shutdown(\Throwable $withError = null)
             return;
         }
 
-        $this->connection->disconnect()->always(function () use ($withError) {
+        if ($withError && !$this->shutdownError) {
+            $this->shutdownError = $withError;
+        }
+
+        $this->connection->disconnect()->always(function () {
             $this->state = self::STATE_FLUSHING;
-            $withError && $this->shutdownError = $withError;
             $this->stopProcess();
         });
     }