Await for a successful connection to the websocket before listening t…

…o messages
braverhealth · Apr 18, 2024 · 6ce168b · 6ce168b
1 parent fb11446
commit 6ce168b
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/lib/src/socket.dart b/lib/src/socket.dart
@@ -190,6 +190,12 @@ class PhoenixSocket {
       _ws = _webSocketChannelFactory != null
           ? _webSocketChannelFactory!(_mountPoint)
           : WebSocketChannel.connect(_mountPoint);
+
+      // Wait for the WebSocket to be ready before continuing. In case of a
+      // failure to connect, the future will complete with an error and will be
+      // caught.
+      await _ws!.ready;
+
       _ws!.stream
           .where(_shouldPipeMessage)
           .listen(_onSocketData, cancelOnError: true)