connectRSocket function

Future<DuplexConnection> connectRSocket(
  1. String url,
  2. TcpChunkHandler handler
)

Implementation

Future<DuplexConnection> connectRSocket(String url, TcpChunkHandler handler) {
  var uri = Uri.parse(url);
  var scheme = uri.scheme;
  if (scheme == 'tcp') {
    var socketFuture = Socket.connect(uri.host, uri.port);
    return socketFuture.then((socket) => TcpDuplexConnection(socket));
  } else if (scheme == 'ws' || scheme == 'wss') {
    var socketFuture = WebSocket.connect(url);
    return socketFuture.then((socket) => WebSocketDuplexConnection(socket));
  } else {
    return Future.error('${scheme} unsupported');
  }
}