bind方法
override
转换提供的stream
。
返回一个新的流,其中包含从提供的stream
的事件计算得出的事件。
StreamTransformer接口是完全通用的,因此它不能说明子类做了什么。每个StreamTransformer都应该清楚地说明如何转换流(在用于访问转换器的类或变量中),以及与以下典型行为的任何差异
- 当监听返回的流时,它开始监听输入的
stream
。 - 返回流的订阅将(在合理的时间内)将一个StreamSubscription.pause调用转发到输入
stream
的订阅。 - 类似地,取消返回流的订阅最终(在合理的时间内)取消输入
stream
的订阅。
"合理时间"取决于转换器和流。一些转换器,如"超时"转换器,可能会使这些操作依赖于一个持续时间。其他转换器可能根本不会延迟它们,或者只是通过微任务。
转换器可以自由地以任何方式处理错误。转换器实现可以选择传播错误、将它们转换为其他事件或完全忽略它们,但如果忽略错误,则应明确记录。
实现
Stream<List<int>> bind(Stream<String> stream) => super.bind(stream);