diff --git a/src/EventLoopBridge.php b/src/EventLoopBridge.php index fcb407a..a3f4172 100644 --- a/src/EventLoopBridge.php +++ b/src/EventLoopBridge.php @@ -131,6 +131,7 @@ private function handleReadEvent(Events\Event $event): void private function handleFutureReadEvent(Events\Event $event): void { $this->futures[spl_object_hash($event->object)]->resolve($event->value); + unset($this->futures[spl_object_hash($event->object)]); } private function handleChannelReadEvent(Events\Event $event): void