diff --git a/lib/src/presenter/hasura_connect_base.dart b/lib/src/presenter/hasura_connect_base.dart
index 74011b0..5b4ce89 100644
--- a/lib/src/presenter/hasura_connect_base.dart
+++ b/lib/src/presenter/hasura_connect_base.dart
@@ -201,7 +201,7 @@ class HasuraConnect {
 
     if (snapmap.keys.isNotEmpty && !_isConnected) {
       // ignore: unawaited_futures
-      _connect();
+      await _connect();
     } else if (_isConnected) {
       final input = querySubscription(snapshot.query);
       sendToWebSocketServer(input);