connect function

Future<StreamChannel> connect(
  1. String host, {
  2. int port = 50002,
  3. Duration connectionTimeout = connectionTimeout,
  4. Duration aliveTimerDuration = aliveTimerDuration,
  5. bool acceptUnverified = true,
})

Implementation

Future<StreamChannel> connect(
  String host, {
  int port = 50002,
  Duration connectionTimeout = connectionTimeout,
  Duration aliveTimerDuration = aliveTimerDuration,
  bool acceptUnverified = true,
}) async {
  var socket = await io.SecureSocket.connect(host, port,
      timeout: connectionTimeout,
      onBadCertificate: acceptUnverified ? (_) => true : null);
  var channel = StreamChannel(socket.cast<List<int>>(), socket);
  var channelUtf8 =
      channel.transform(StreamChannelTransformer.fromCodec(convert.utf8));
  var channelJson = jsonNewlineDocument
      .bind(channelUtf8)
      .transformStream(utils.ignoreFormatExceptions);
  return channelJson;
}