accumulatedBehaviourStream<T> function

BehaviorSubject<IList<T>> accumulatedBehaviourStream<T>(
  1. Stream<IList<T>> stream
)

Implementation

BehaviorSubject<IList<T>> accumulatedBehaviourStream<T>(
  Stream<IList<T>> stream,
) {
  final accStream = accumulatedStream(stream);
  final subject = BehaviorSubject<IList<T>>(sync: true);
  subject.addStream(accStream).whenComplete(subject.close);
  return subject;
}