fix(channel): return immediately after cancelling send/recieve callbacks

azjezz · Nov 23, 2021 · ced10a2 · ced10a2
1 parent 23a5a61
commit ced10a2
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 0 deletions.
diff --git a/src/Psl/Channel/Internal/Receiver.php b/src/Psl/Channel/Internal/Receiver.php
@@ -42,6 +42,8 @@ public function receive(): mixed
             Async\Scheduler::repeat(0.0001, function (string $identifier): void {
                 if (null === $this->deferred) {
                     Async\Scheduler::cancel($identifier);
+
+                    return;
                 }
 
                 if ($this->state->isClosed()) {

diff --git a/src/Psl/Channel/Internal/Sender.php b/src/Psl/Channel/Internal/Sender.php
@@ -42,6 +42,8 @@ public function send(mixed $message): void
             Async\Scheduler::repeat(0.0001, function (string $identifier): void {
                 if (null === $this->deferred) {
                     Async\Scheduler::cancel($identifier);
+
+                    return;
                 }
 
                 if ($this->state->isClosed()) {