async library

Classes

AsyncCache<T>
运行异步函数并将结果缓存一段时间. [...]
AsyncMemoizer<T>
一个类,用于只运行一次异步函数并缓存其结果. [...]
CancelableCompleter<T>
CancelableOperation的完成者.
CancelableOperation<T>
可以取消的异步操作. [...]
DelegatingEventSink<T>
EventSink周围的简单委托包装器. [...]
DelegatingFuture<T>
将请求转发到Future的包装器.
DelegatingSink<T>
一个简单的委派包装器围绕在水槽上 . [...]
DelegatingStream<T>
一个围绕Stream的简单委派包装器. [...]
DelegatingStreamConsumer<T>
StreamConsumer周围的简单委派包装器. [...]
DelegatingStreamSink<T>
围绕StreamSink的简单委托包装器. [...]
DelegatingStreamSubscription<T>
StreamSubscription周围的简单委派包装器. [...]
ErrorResult
表示抛出错误的结果.
FutureGroup<T>
期货集合会等到所有添加的Future完成. [...]
LazyStream<T>
一个Stream包装器,它转发到延迟初始化的另一个Stream . [...]
NullStreamSink<T>
丢弃所有事件的StreamSink . [...]
RestartableTimer
一个非周期性计时器,可以重新启动任何次数. [...]
Result<T>
The result of a computation. [...]
ResultFuture<T>
一个Future包装器,一旦完成,它就提供对包装的Future的结果的同步访问.
SingleSubscriptionTransformer<S, T>
将广播流转换为单订阅流的转换器. [...]
StreamCompleter<T>
单订阅 ,稍后将提供内容. [...]
StreamGroup<T>
流的集合,其事件是统一的并通过中央流发送. [...]
StreamQueue<T>
基于异步提取的接口,用于访问流事件. [...]
StreamQueueTransaction<T>
在一个事务StreamQueue ,通过创建StreamQueue.startTransaction . [...]
StreamSinkCompleter<T>
水槽其中目的地是稍后提供. [...]
StreamSinkTransformer<S, T>
StreamSinkTransformer将传递到接收器的事件转换. [...]
StreamSplitter<T>
一个类,它将单个源流分成发出相同事件的任意数量的(单预订)流(称为"分支"). [...]
StreamZip<T>
合并其他流的值的流. [...]
SubscriptionStream<T>
用于StreamSubscription的 Stream适配器. [...]
ValueResult<T>
代表返回值的结果.

Functions

collectBytes(Stream<List<int>> source) Future<Uint8List>
将字节列表的异步序列收集到单个字节列表中. [...]
collectBytesCancelable(Stream<List<int>> source) CancelableOperation<Uint8List>
将字节列表的异步序列收集到单个字节列表中. [...]
subscriptionTransformer<T>({Future handleCancel(StreamSubscription<T>), void handlePause(StreamSubscription<T>), void handleResume(StreamSubscription<T>)}) StreamTransformer<T, T>
创建一个StreamTransformer ,以修改对流的订阅行为. [...]
typedStreamTransformer<S, T>(StreamTransformer transformer) StreamTransformer<S, T>
创建一个包装器,以强制transformer器的类型. [...]
@ 不推荐使用 ("在绑定转换器后使用Stream.cast代替")