PropertyStreamSubscription<T> constructor

PropertyStreamSubscription<T>({
  1. required Stream<T> stream,
  2. required Future<void> onCancel(),
  3. required dynamic onData(
    1. T
    ),
})

Implementation

PropertyStreamSubscription({
  required Stream<T> stream,
  required Future<void> Function() onCancel,
  required Function(T) onData,
})  : _stream = stream,
      _onCancel = onCancel {
  _internalSub = _stream.listen(onData);
}