diff --git a/src/TcpConnector.php b/src/TcpConnector.php index 90d7df18..ee0efd4d 100644 --- a/src/TcpConnector.php +++ b/src/TcpConnector.php @@ -112,10 +112,11 @@ private function waitForStreamOnce($stream) $resolve(new Connection($stream, $loop)); } }); - }, function () use ($loop, $stream) { + }, function ($resolve, $reject, $progress) use ($loop, $stream) { $loop->removeWriteStream($stream); fclose($stream); + $resolve = $reject = $progress = null; throw new RuntimeException('Cancelled while waiting for TCP/IP connection to be established'); }); }