connect method

  1. @override
Future<void> connect()
override

connect to web socket ///

Implementation

@override
Future<void> connect() async {
  _socket = await WebSocket.connect(_url);
  onOpen?.call();
  _socket.listen((e) {
    onMessage?.call(e);
  }, onDone: () {
    onClose?.call(_socket.closeCode!, (_socket.closeReason?.isEmpty == true ? "Socket was close":_socket.closeReason!));
  }, onError: (e){
    onClose?.call(500, e.toString());
  });
}