stream_transform library

Extensions

AsyncExpand on Stream<T>
Alternatives to asyncExpand.
AsyncMap on Stream<T>
Alternatives to asyncMap.
CombineLatest on Stream<T>
Utilities to combine events from multiple streams through a callback or into a list.
Concatenate on Stream<T>
Utilities to append or prepend to a stream.
Merge on Stream<T>
Utilities to interleave events from multiple streams.
RateLimit on Stream<T>
Utilities to rate limit events.
Scan on Stream<T>
A utility similar to fold which emits intermediate accumulations.
Switch on Stream<T>
A utility to take events from the most recent sub stream returned by a callback.
SwitchLatest on Stream<Stream<T>>
A utility to take events from the most recent sub stream.
TakeUntil on Stream<T>
A utility to end a stream based on an external trigger.
Tap on Stream<T>
A utility to chain extra behavior on a stream.
Where on Stream<T>
Utilities to filter events.
WhereNotNull on Stream<T?>