PropertyStreamData<T> constructor

PropertyStreamData<T>({
  1. required Stream stream,
  2. required void onUnsubscribe(),
})

Implementation

PropertyStreamData({
  required Stream<dynamic> stream,
  required void Function() onUnsubscribe,
})  : _onUnsubscribe = onUnsubscribe,
      stream = stream.where((e) => e is T).cast<T>();