StreamFlow<T> constructor

StreamFlow<T>(
  1. Stream<T> stream,
  2. T initialValue
)

Implementation

StreamFlow(
  Stream<T> stream,
  T initialValue,
) : super(initialValue) {
  _streamSubscription = stream.listen(emit);
}