stream_transform 0.0.10 stream_transform: ^0.0.10 copied to clipboard
A collection of utilities to transform and manipulate streams.
0.0.10 #
-
Updates to support Dart 2.0 core library changes (wave 2.2). See issue 31847 for details.
0.0.9 #
- Add
asyncMapBuffer
.
0.0.8 #
- Add
takeUntil
.
0.0.7 #
- Bug Fix: Streams produced with
scan
andswitchMap
now 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
,asyncWhere
andaudit
. - Bug Fix: Only call the
tap
data callback once per event rather than once per listener. - Bug Fix: Allow canceling and re-listening to broadcast streams after a
merge
transform. - 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
StreamControllers
for forwarding where possible.
0.0.5 #
- Bug Fix: Allow compiling switchLatest with Dart2Js.
- Add
asyncWhere
: Likewhere
but 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
switchMap
andswitchLatest
: 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
merge
andmergeAll
: Interleaves streams
0.0.1 #
- Initial release with the following utilities:
buffer
: Collects events in aList
until atrigger
stream fires.debounce
,debounceBuffer
: Collect or drop events which occur closer in time than a given duration.