Name: stream_transform
Owner: Dart
Description: Dart utility methods to create StreamTransfomer instances to manipulate Streams
Created: 2017-05-01 19:14:42.0
Updated: 2018-05-24 18:16:44.0
Pushed: 2018-05-24 18:16:45.0
Homepage: https://pub.dartlang.org/packages/stream_transform
Size: 70
Language: Dart
GitHub Committers
User | Most Recent Commit | # Commits |
---|
Other Committers
User | Most Recent Commit | # Commits |
---|
Utility methods to create StreamTransfomer
instances to manipulate Streams.
Like asyncMap
but events are buffered until previous events have been
processed.
Like where
but allows an asynchronous predicate.
Audit waits for a period of time after receiving a value and then only emits the most recent value.
Collects values from a source stream until a trigger
stream fires and the
collected values are emitted.
Prevents a source stream from emitting too frequently by dropping or collecting values that occur within a given duration.
Appends the values of a stream after another stream finishes.
Interleaves events from multiple streams into a single stream.
Scan is like fold, but instead of producing a single value it yields each intermediate accumulation.
Prepend a value, an iterable, or a stream to the beginning of another stream.
Flatten a Stream of Streams into a Stream which forwards values from the most recent Stream
Let values through until a Future fires.
Taps into a single-subscriber stream to react to values as they pass, without being a real subscriber.
Blocks events for a duration after an event is successfully emitted.