expand<S> 方法
- Iterable<
S> convert(- T element
将此流中的每个元素转换为一系列元素。
返回一个新的流,其中该流的每个元素都由零个或多个数据事件替换。事件值通过带有元素作为参数的 convert
调用提供,并将迭代器中的元素按顺序发出。如果调用 convert
�抛出异常,或者如果返回值的迭代抛出异常,则错误会发射到返回的流上,并且该流元素的迭代结束。
将错误事件和此流的完成事件直接转发到返回的流。
如果此流是广播流,则返回的流是广播流。如果多次监听广播流,则每个订阅将单独调用 convert
并扩展事件。
实现
Stream<S> expand<S>(Iterable<S> convert(T element)) {
return new _ExpandStream<T, S>(this, convert);
}