SubscriptionClient constructor
Implementation
SubscriptionClient(
Uri uri, {
Duration? pingInterval,
Duration? connectTimeout,
}) {
final channel = IOWebSocketChannel.connect(
uri,
pingInterval: pingInterval,
connectTimeout: connectTimeout,
);
_sink = channel.sink;
_stream = channel.stream.asBroadcastStream();
}