Always rethrow errors in DriverSuspension (#31)

Author: bwoebi

src/EventLoop/Internal/DriverSuspension.php

@@ -77,15 +77,15 @@ public function suspend(): mixed
         }
 
         // Awaiting from {main}.
-        $lambda = ($this->run)();
+        $result = ($this->run)()();
 
         /** @psalm-suppress RedundantCondition $this->pending should be changed when resumed. */
         if ($this->pending) {
             // Should only be true if the event loop exited without resolving the promise.
             throw new \Error('Scheduler suspended or exited unexpectedly');
         }
 
-        return $lambda();
+        return $result;
     }
 
     public function throw(\Throwable $throwable): void

test/EventLoopTest.php

@@ -197,4 +197,18 @@ public function testSuspensionWithinQueue(): void
 
         self::assertSame($send, $received);
     }
+
+    public function testSuspensionThrowingErrorViaInterrupt(): void
+    {
+        $suspension = EventLoop::createSuspension();
+        $error = new \Error("Test error");
+        EventLoop::queue(static fn () => throw $error);
+        EventLoop::defer(static fn () => $suspension->resume("Value"));
+        try {
+            $suspension->suspend();
+            self::fail("Error was not thrown");
+        } catch (\Throwable $t) {
+            self::assertSame($error, $t);
+        }
+    }
 }