connect method

Future<void> connect({
  1. required String url,
  2. required YKSocketDelegate delegate,
})

连接

Implementation

Future<void> connect({required String url, required YKSocketDelegate delegate}) async {
  if (_state == SocketState.connected || _state == SocketState.connecting) {
    return;
  }
  _delegate = delegate;

  _url = url;
  _updateState(SocketState.connecting);

  try {
    _webSocket = await WebSocket.connect(url);
    _setupWebSocket(_webSocket!);
    _reconnectAttempts = 0;
    _delegate?.onConnectSuccess?.call();
  } catch (e) {
    _delegate?.onConnectFail?.call();
    _delegate?.onError?.call('Connection failed: $e');
    _handleConnectionError();
  }
}