stream_transform library

Extensions

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