SubscriptionClient constructor

SubscriptionClient(
  1. Uri uri, {
  2. Duration? pingInterval,
  3. Duration? connectTimeout,
})

Implementation

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