Add missing suspension resume

Fixes #14.
amphp · Feb 13, 2024 · 81774a2 · 81774a2
1 parent 5db4718
commit 81774a2
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/src/Internal/StreamResourceSendPipe.php b/src/Internal/StreamResourceSendPipe.php
@@ -64,6 +64,8 @@ static function (string $callbackId, $stream) use (
                             $transferQueue->unshift([$suspension, $export, $data]);
                             return;
                         }
+
+                        $suspension->resume();
                     } catch (\Throwable $exception) {
                         $suspension->resume(static fn () => throw new SocketException(
                             'Failed to send socket: ' . $exception->getMessage(),