diff --git a/src/WebSockets/WebSocketHandler.php b/src/WebSockets/WebSocketHandler.php index a10dc1f..8b363d2 100644 --- a/src/WebSockets/WebSocketHandler.php +++ b/src/WebSockets/WebSocketHandler.php @@ -170,6 +170,8 @@ class WebSocketHandler implements MessageComponentInterface if ($connectionsCount instanceof PromiseInterface) { $connectionsCount->then(function ($connectionsCount) use ($capacity, $connection) { + $connectionsCount = $connectionsCount ?: 0; + $this->sendExceptionIfOverCapacity($connectionsCount, $capacity, $connection); }); } else {