connect function

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

Implementation

Future<StreamChannel> connect(dynamic host,
    {port = 50002,
    connectionTimeout = connectionTimeout,
    aliveTimerDuration = aliveTimerDuration,
    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;
}