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