connect method

Implementation

Future<RSocket> connect(String url) async {
  TcpChunkHandler handler = (Uint8List chunk) {};
  var connectionSetupPayload = ConnectionSetupPayload()
    ..keepAliveInterval = keepAliveInterval * 1000
    ..keepAliveMaxLifetime = keepAliveMaxLifeTime * 1000
    ..metadataMimeType = _metadataMimeType
    ..dataMimeType = _dataMimeType
    ..data = payload?.data
    ..metadata = payload?.metadata;
  return connectRSocket(url, handler).then((conn) {
    var rsocketRequester =
        RSocketRequester('requester', connectionSetupPayload, conn);
    if (_acceptor != null) {
      rsocketRequester.responder =
          _acceptor!(connectionSetupPayload, rsocketRequester);
      if (rsocketRequester.responder == null) {
        rsocketRequester.close();
        return Future.error(
            'RSOCKET-0x00000003: Connection refused, please check setup and security!');
      }
    } else {
      rsocketRequester.responder = RSocket();
    }
    rsocketRequester.errorConsumer = _errorConsumer;
    rsocketRequester.sendSetupPayload();
    return rsocketRequester;
  });
}