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