接受多个完整流的“汇”的抽象接口。
消费者可以使用 addStream 接受一系列连续的流,当不再需要添加数据时,close 方法会通知消费者完成其工作并关闭。
Stream.pipe 接受一个 StreamConsumer
,并将流传递给消费者的 addStream 方法。当这完成时,它将调用 close 并完成其返回的 future。
- 实现者
属性
- hashCode → int
- 此对象的哈希码。无设置器继承
- runtimeType → Type
- 对象的运行时类型的表示。无设置器继承
方法
-
addStream(
Stream< S> stream) → Future - 消费
stream
的元素。 -
close(
) → Future - 通知消费者不再添加流。
-
noSuchMethod(
Invocation invocation) → dynamic - 当访问不存在的方法或属性时调用。继承
-
toString(
) → String - 此对象的字符串表示。继承
操作符
-
operator ==(
Object other) → bool - 相等操作符。继承