dart-lang/stream_transform

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

UserMost Recent Commit# Commits

Other Committers

UserEmailMost Recent Commit# Commits

README

Utility methods to create StreamTransfomer instances to manipulate Streams.

asyncMapBuffer

Like asyncMap but events are buffered until previous events have been processed.

asyncWhere

Like where but allows an asynchronous predicate.

audit

Audit waits for a period of time after receiving a value and then only emits the most recent value.

buffer

Collects values from a source stream until a trigger stream fires and the collected values are emitted.

debounce, debounceBuffer

Prevents a source stream from emitting too frequently by dropping or collecting values that occur within a given duration.

followedBy

Appends the values of a stream after another stream finishes.

merge, mergeAll

Interleaves events from multiple streams into a single stream.

scan

Scan is like fold, but instead of producing a single value it yields each intermediate accumulation.

startWith, startWithMany, startWithStream

Prepend a value, an iterable, or a stream to the beginning of another stream.

switchMap, switchLatest

Flatten a Stream of Streams into a Stream which forwards values from the most recent Stream

takeUntil

Let values through until a Future fires.

tap

Taps into a single-subscriber stream to react to values as they pass, without being a real subscriber.

throttle

Blocks events for a duration after an event is successfully emitted.


This work is supported by the National Institutes of Health's National Center for Advancing Translational Sciences, Grant Number U24TR002306. This work is solely the responsibility of the creators and does not necessarily represent the official views of the National Institutes of Health.