Utility methods to create
StreamTransfomer instances to manipulate Streams.
asyncMap but events are buffered until previous events have been
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.
Appends the values of a stream after another stream finishes.
Prevents a source stream from emitting too frequently by dropping or collecting values that occur within a given duration.
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.
switchMapnow correctly report
tapdata callback once per event rather than once per listener.
StreamControllersfor forwarding where possible.
wherebut allows an asynchronous predicate.
scan: fold which returns intermediate values
throttle: block events for a duration after emitting a value
audit: emits the last event received after a duration
tap: React to values as they pass without being a subscriber on a stream
switchLatest: Flatten a Stream of Streams into a Stream which forwards values from the most recent Stream
concat: Appends streams in series
mergeAll: Interleaves streams
buffer: Collects events in a
debounceBuffer: Collect or drop events which occur closer in time than a given duration.
Add this to your package's pubspec.yaml file:
dependencies: stream_transform: "^0.0.9"
You can install packages from the command line:
$ pub get
Alternatively, your editor might support 'pub get'. Check the docs for your editor to learn more.
Now in your Dart code, you can use:
|0.0.9||Aug 7, 2017||Go to the documentation of stream_transform 0.0.9||Download stream_transform 0.0.9 archive|
|0.0.8||Aug 4, 2017||Go to the documentation of stream_transform 0.0.8||Download stream_transform 0.0.8 archive|
|0.0.7||Jul 12, 2017||Go to the documentation of stream_transform 0.0.7||Download stream_transform 0.0.7 archive|
|0.0.6||Jul 11, 2017||Go to the documentation of stream_transform 0.0.6||Download stream_transform 0.0.6 archive|
|0.0.5||May 8, 2017||Go to the documentation of stream_transform 0.0.5||Download stream_transform 0.0.5 archive|
|0.0.4||May 7, 2017||Go to the documentation of stream_transform 0.0.4||Download stream_transform 0.0.4 archive|
|0.0.3||May 6, 2017||Go to the documentation of stream_transform 0.0.3||Download stream_transform 0.0.3 archive|
|0.0.2||May 5, 2017||Go to the documentation of stream_transform 0.0.2||Download stream_transform 0.0.2 archive|
|0.0.1||May 2, 2017||Go to the documentation of stream_transform 0.0.1||Download stream_transform 0.0.1 archive|