WebsocketNotifier<T> constructor

WebsocketNotifier<T>(
  1. String subscribeMethod, {
  2. required SubscriptionId subscriptionId,
  3. required bool autoUnsubscribes,
  4. required bool cancelOnError,
  5. required JsonRpcNotificationDecoder<T> decoder,
  6. required Duration? timeLimit,
  7. required void onTimeout()?,
})

Creates a notification dispatcher.

Implementation

WebsocketNotifier(
  this.subscribeMethod, {
  required this.subscriptionId,
  required this.autoUnsubscribes,
  required this.cancelOnError,
  required this.decoder,
  required final Duration? timeLimit,
  required void Function()? onTimeout,
})  : assert(timeLimit == null || onTimeout != null),
      _timer = timeLimit != null && onTimeout != null
          ? Timer(timeLimit, onTimeout)
          : null;