connect method

@override Future<void> connect()

Implementation

@override
Future<void> connect() async {
  if (_sig == null) {
    var sig = _RoomGRPCClient(connector, this);
    sig.on('join-reply', (JoinResult result) => onJoin?.call(result));
    sig.on('leave-reply', (String reason) => onLeave?.call(reason));
    sig.on('peer-event', (PeerEvent event) => onPeerEvent?.call(event));
    sig.on('message', (Message msg) => onMessage?.call(msg));
    sig.on('room-info', (RoomInfo info) => onRoomInfo?.call(info));
    sig.on('disconnect', (Disconnect disc) => onDisconnect?.call(disc));
    sig.on('error', (Error err) => onError?.call(err));
    sig.connect();
    _sig = sig;
  }
}