streams library

Classes

AsyncValueStream<T>
The AsyncValueStream is used as a clearing house when more than one consumer need to update a single value, but you want to control the lifecycle around updates, so that older updates that take longer to calculate don't clobber newer values.
FStream<T>
A value stream based where the first element is a future
FuturesStream
HeadedEntryStream<K, V>
HStream<T>
SyncStream<T>
The SyncStream is used to control (and potentially debounce) updates to a single value, that are then dispatched as a single stream of updates
UpdateRequest<T>
UpdateResult<T>
ValueStream<T>
Interface representing a stream that has a current or initial value as well.
ValueStreamController<T>
A class that tracks a single value as a stream, but can also provide the latest value;

Functions

streamOfNullableFuture<T>(Future<T?>? nullable) → Stream<T>