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