bind 方法

Stream<String> bind(
  1. Stream<List<int>>
)
override

将提供的 stream 进行转换。

返回一个新的流,其事件是从提供的 stream 的事件计算得出的。

StreamTransformer 接口是完全通用的,因此无法说明它的子类做了什么。每个 StreamTransformer 都应该清楚地记录如何转换流(在用于访问转换器的类或变量中),以及与以下典型行为的任何差异

  • 当监听返回的流时,它开始监听输入的 stream
  • 返回流的订阅将(在合理的时间内)将 StreamSubscription.pause 调用传递给输入 stream 的订阅。
  • 类似地,取消返回流的订阅最终(在合理的时间内)取消输入 stream 的订阅。

"合理时间"取决于转换器和流。某些转换器,如 "timeout" 转换器,可能会使这些操作依赖于一个持续时间。其他的可能根本不延迟,或者是微任务级别的延迟。

转换器可以自由地以任何方式处理错误。转换器实现可以选择传播错误,或将它们转换为其他事件,或完全忽略它们,但如果忽略错误,则应明确记录。

实现

Stream<String> bind(Stream<List<int>> stream) => super.bind(stream);