stream_transform 0.0.7
stream_transform: ^0.0.7 copied to clipboard
A collection of utilities to transform and manipulate streams.
0.0.7 #
- Bug Fix: Streams produced with
scanandswitchMapnow correctly reportisBroadcast. - Add
startWith,startWithMany, andstartWithStream.
0.0.6 #
- Bug Fix: Some transformers did not correctly add data to all listeners on
broadcast streams. Fixed for
throttle,debounce,asyncWhereandaudit. - Bug Fix: Only call the
tapdata callback once per event rather than once per listener. - Bug Fix: Allow canceling and re-listening to broadcast streams after a
mergetransform. - Bug Fix: Broadcast streams which are buffered using a single-subscription trigger can be canceled and re-listened.
- Bug Fix: Buffer outputs one more value if there is a pending trigger before the trigger closes.
- Bug Fix: Single-subscription streams concatted after broadcast streams are handled correctly.
- Use sync
StreamControllersfor forwarding where possible.
0.0.5 #
- Bug Fix: Allow compiling switchLatest with Dart2Js.
- Add
asyncWhere: Likewherebut allows an asynchronous predicate.
0.0.4 #
- Add
scan: fold which returns intermediate values - Add
throttle: block events for a duration after emitting a value - Add
audit: emits the last event received after a duration
0.0.3 #
- Add
tap: React to values as they pass without being a subscriber on a stream - Add
switchMapandswitchLatest: Flatten a Stream of Streams into a Stream which forwards values from the most recent Stream
0.0.2 #
- Add
concat: Appends streams in series - Add
mergeandmergeAll: Interleaves streams
0.0.1 #
- Initial release with the following utilities:
buffer: Collects events in aListuntil atriggerstream fires.debounce,debounceBuffer: Collect or drop events which occur closer in time than a given duration.