接受多个完整流流的“汇”的抽象接口。
消费者可以使用 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 - 平等运算符。继承