quiver.async library

Classes

CountdownTimer
一个简单的倒数计时器,可以按固定的增量触发事件,直到持续时间过去为止. [...]
FutureStream<T>
一旦future完成,将发出与future返回的流相同的值的流. [...]
Metronome
为中心的间隔为 s的DateTime事件流. [...]
StreamBuffer<T>
允许从数据流(例如Socket)中有序读取元素,这些数据流可能不会接收List<int>个字节的常规块. [...]
StreamRouter<T>
根据一组谓词将事件拆分为多个流. [...]

Functions

collect<T>(Iterable<Future<T>> futures) Stream<T>
返回输入futures的完成事件流. [...]
concat<T>(Iterable<Stream<T>> streams) Stream<T>
返回输入流的内容. [...]
doWhileAsync<T>(Iterable<T> iterable, AsyncAction<bool, T> action) Future<bool>
呼吁action对每个项目iterable反过来,等待未来返回的行动来完成. [...]
@ 弃用 ("从dart:async使用Future.doWhile.将从3.0.0中删除.")
enumerate<T>(Stream<T> stream) Stream<IndexedValue<T>>
返回一个IndexedValueStream ,其中第n个值保存stream的第n个元素及其索引.
forEachAsync<T>(Iterable<T> iterable, AsyncAction<Null, T> action, {int maxTasks: 1}) Future<Null>
附表呼吁action中的每个元素iterable . 不超过maxTasks呼吁action将立即被挂起.
reduceAsync<S, T>(Iterable<T> iterable, S initialValue, AsyncCombiner<S, T> combine) Future<S>
通过使用提供的combine函数迭代合并集合的元素,将集合减少为单个值. 与Iterable.reduce相似,不同之处在于combine是一个返回Future的异步函数.

Typedefs

AsyncAction<T, E>(E e) Future<T>
返回值的异步回调.
AsyncCombiner<T, E>(T previous, E e) Future<T>
异步funcuntion结合的元素e与先前值previous ,用于在使用reduceAsync .

Exceptions / Errors

UnderflowError
当仍然有阻塞的读取器时,当套接字提供缓冲区的操作完成时,就会发生下溢错误. 每个读者都将完成此错误.