connect method

Future<void> connect()

Implementation

Future<void> connect() async {
  if (_isConnected) {
    return;
  }

  try {
    final wsUrl = _buildWebSocketUrl();
    _webSocketChannel = WebSocketChannel.connect(Uri.parse(wsUrl));
    _isConnected = true;

    _webSocketChannel!.stream.listen(
      _handleMessage,
      onError: _handleError,
      onDone: _handleDisconnect,
    );
  } catch (e) {
    _isConnected = false;
    rethrow;
  }
}