connect method

Future<void> connect()

Implementation

Future<void> connect() async {
  _socket = WebSocket(_url);
  _socket.onOpen.listen((e) {
    onOpen?.call();
  });

  _socket.onMessage.listen((e) {
    onMessage?.call(e.data);
  });

  _socket.onError.listen((e) {
    onClose?.call(500, e.toString());
  });

  _socket.onClose.listen((e) {
    onClose?.call(e.code!, (e.reason?.isEmpty == true ? "Socket was close":e.reason!));
  });
}