Additional stopped check

revoltphp · Dec 7, 2024 · 883521f · 883521f
1 parent 607623a
commit 883521f
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/src/EventLoop/Internal/AbstractDriver.php b/src/EventLoop/Internal/AbstractDriver.php
@@ -91,6 +91,10 @@ public function __construct()
         $this->queueCallback = $this->queue(...);
         $this->runCallback = function (): ?\Closure {
             do {
+                if ($this->stopped) {
+                    return null;
+                }
+
                 if ($this->fiber->isTerminated()) {
                     $this->createLoopFiber();
                 }