Subscription constructor

Subscription(
  1. Stream<TRMessage> messages,
  2. Future<void> ready, {
  3. Future<void> onUnsubscribe()?,
})

Creates a Subscription. onUnsubscribe is an optional callback invoked when unsubscribe() is called.

Implementation

Subscription(this.messages, this.ready,
    {Future<void> Function()? onUnsubscribe})
    : _onUnsubscribe = onUnsubscribe;