PipeSubscription<Notification extends Object> constructor

PipeSubscription<Notification extends Object>({
  1. required Stream<Notification> stream,
  2. required Future<void> unsubscribe(),
})

Implementation

PipeSubscription({
  required Stream<Notification> stream,
  required Future<void> Function() unsubscribe,
})  : _unsubscribe = unsubscribe,
      super(stream);