A simple countdown timer that fires events in regular increments until a duration has passed. [...]
A collection of Futures that signals when all added Futures complete. New Futures can be added to the group as long as it hasn't completed. [...]
A Stream that will emit the same values as the stream returned by future once future completes. [...]
A stream of DateTime events at intervals centered on anchor. [...]
Allow orderly reading of elements from a datastream, such as Socket, which might not receive List bytes regular chunks. [...]
Splits a Stream of events into multiple Streams based on a set of predicates. [...]


collect<T>(Iterable<Future<T>> futures) Stream<T>
Returns a stream of completion events for the input futures. [...]
concat<T>(Iterable<Stream<T>> streams) Stream<T>
Returns the concatentation of the input streams. [...]
createTimer(Duration duration, void callback()) Timer
Creates a new one-shot Timer using new Timer(duration, callback). [...]
createTimerPeriodic(Duration duration, void callback(Timer t)) Timer
Creates a new periodic Timer using new Timer.periodic(duration, callback). [...]
doWhileAsync<T>(Iterable<T> iterable, AsyncAction<bool, T> action) Future<bool>
Calls action for each item in iterable in turn, waiting for the Future returned by action to complete. [...]
enumerate<T>(Stream<T> stream) Stream<IndexedValue<T>>
Returns a Stream of IndexedValues where the nth value holds the nth element of stream and its index.
forEachAsync<T>(Iterable<T> iterable, AsyncAction<Null, T> action, { int maxTasks: 1 }) Future<Null>
Schedules calls to action for each element in iterable. No more than maxTasks calls to action will be pending at once.
reduceAsync<S, T>(Iterable<T> iterable, S initialValue, AsyncCombiner<S, T> combine) Future<S>
Reduces a collection to a single value by iteratively combining elements of the collection using the provided combine function. Similar to Iterable.reduce, except that combine is an async function that returns a Future.


AsyncAction<T, E>(E e) Future<T>
An asynchronous callback that returns a value.
AsyncCombiner<T, E>(T previous, E e) Future<T>
An asynchronous funcuntion that combines an element e with a previous value previous, for use with reduceAsync.
CreateTimer(Duration duration, void callback()) Timer
The signature of a one-shot Timer factory.
CreateTimerPeriodic(Duration duration, void callback(Timer)) Timer
The signature of a periodic timer factory.

Exceptions / Errors

Underflow errors happen when the socket feeding a buffer is finished while there are still blocked readers. Each reader will complete with this error.