RxJS - 转换运算符扩展

expand 运算符将一个函数作为参数，该函数递归地应用于 source 可观察对象，也应用于 output 可观察对象。最终值是一个可观察对象。

语法

expand(recursive_func:observable): Observable

参数

recursive_func − 一个函数，应用于来自 source 的所有值，并返回一个 Observable。

返回值

一个 observable，具有 recursive_func 结果的值。

示例

import { of } from 'rxjs';
import { expand } from 'rxjs/operators';

let buffered_array = of(2).pipe(expand(x => of(2 * x)));
buffered_array.subscribe(arr => console.log(arr));

输出