chore: move connect method inside the try-catch

deriv-com · Nov 20, 2024 · dca26f1 · dca26f1
1 parent 77e6a08
commit dca26f1
Show file tree

Hide file tree

Showing 2 changed files with 23 additions and 21 deletions.
diff --git a/lib/services/connection/api_manager/binary_api.dart b/lib/services/connection/api_manager/binary_api.dart
@@ -131,8 +131,6 @@ class BinaryAPI extends BaseAPI {
     _webSocketChannel = IOWebSocketChannel.connect('$uri',
         pingInterval: _keepAlivePingInterval, customClient: client);
 
-    unawaited(_webSocketChannel?.ready.then((_) => _startConnectionTimer()));
-
     _webSocketListener = _webSocketChannel?.stream
         .map<Map<String, dynamic>?>((Object? result) => jsonDecode('$result'))
         .listen(
@@ -162,6 +160,10 @@ class BinaryAPI extends BaseAPI {
       },
     );
 
+    await _webSocketChannel?.ready;
+
+    _startConnectionTimer();
+
     _logDebugInfo('send initial message.');
   }
 

diff --git a/lib/state/connection/connection_cubit.dart b/lib/state/connection/connection_cubit.dart
@@ -85,31 +85,31 @@ class ConnectionCubit extends Cubit<ConnectionState> {
 
     try {
       await _api.disconnect().timeout(_pingTimeout);
+
+      await _api.connect(
+        _connectionInformation,
+        onOpen: (String key) {
+          if (_key == key) {
+            emit(const ConnectionConnectedState());
+          }
+        },
+        onDone: (String key) {
+          if (_key == key) {
+            unawaited(reconnect());
+          }
+        },
+        onError: (String key) {
+          if (_key == key) {
+            emit(const ConnectionDisconnectedState());
+          }
+        },
+      ).timeout(_pingTimeout);
     } on Exception catch (e) {
       dev.log('$runtimeType disconnect exception: $e', error: e);
 
       unawaited(reconnect());
 
       return;
     }
-
-    await _api.connect(
-      _connectionInformation,
-      onOpen: (String key) {
-        if (_key == key) {
-          emit(const ConnectionConnectedState());
-        }
-      },
-      onDone: (String key) {
-        if (_key == key) {
-          unawaited(reconnect());
-        }
-      },
-      onError: (String key) {
-        if (_key == key) {
-          emit(const ConnectionDisconnectedState());
-        }
-      },
-    );
   }
 }