StreamSink<S> 类 抽象 接口

一个可以同步和异步接受流事件的对象。

StreamSink 结合了 StreamConsumer 和 EventSink 的方法。

在调用 addStream 时不能使用 EventSink 的方法。一旦 addStream 的 Future 完成并返回一个值，就可以再次使用 EventSink 的方法。

如果 addStream 在任何 EventSink 方法之后被调用，它将被延迟，直到底层系统消耗了 EventSink 方法添加的数据。

使用 EventSink 方法时，可以使用 done Future 来捕获任何错误。

调用 close 时，将返回 done Future。

实现类型
实现者

构造函数

StreamSink()

属性

done → Future
返回一个 StreamSink 完成时的 future。
无设置器
hashCode → int
此对象的哈希码。
无设置器继承
runtimeType → Type
对象运行时类型的表示。
无设置器继承

方法

add(S event) → void
将数据 event 添加到接收器。
继承
addError(Object error, [StackTrace? stackTrace]) → void
向接收器添加 error。
继承
addStream(Stream<S> stream) → Future
消费 stream 的元素。
继承
close() → Future
告知流接收器不再添加更多的流。
覆盖
noSuchMethod(Invocation invocation) → dynamic
当访问不存在的方法或属性时调用。
继承
toString() → String
此对象的字符串表示。
继承

运算符

operator ==(Object other) → bool
相等运算符。
继承