StreamSink<S> 类 抽象 接口

一个既可以同步也可以异步接收流事件的对象。

StreamSink 结合了来自 StreamConsumer 和 EventSink 的方法。

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

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

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

当调用 close 时，它将返回 done Future。

实现类型
实现者

属性

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

方法

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

操作符

operator ==(Object other) → bool
等号操作符。
继承