pipe方法

Future pipe(

)

将此流的的事件传递到streamConsumer。

使用StreamConsumer.addStream将此流的所有事件添加到streamConsumer。当此流成功添加到其中时，即当由addStream返回的future完成且没有错误时，将关闭streamConsumer。

返回一个future，当此流被消费并且消费者被关闭时完成。

返回的future以与StreamConsumer.close返回的future相同的结果完成。如果StreamConsumer.addStream的调用以某种方式失败，此方法也会以相同的方式失败。

实现

Future pipe(StreamConsumer<T> streamConsumer) {
  return streamConsumer.addStream(this).then((_) => streamConsumer.close());
}