rxjs pipe和map组合的一个实际例子的单步调试

时间:2022-07-25
本文章向大家介绍rxjs pipe和map组合的一个实际例子的单步调试，主要内容包括其使用实例、应用技巧、基本知识点总结和需要注意事项，具有一定的参考价值，需要的朋友可以参考一下。

原始代码：

console.log('before ngOnInit');
    const source$ = range(0, 10);


    source$.pipe(
      /*filter(
        (x, index) => {
        console.log('inside filter!: ' + x + ' index: ' + index);
        return x % 2 === 0 })
        */ 
      map( x => { 
        console.log('inside map: ' + x);
        return (x + x); }
        )
        /*
      // scan((acc, x) => acc + x, 0)
      scan(this.accumulator)*/
    )
    .subscribe(x => console.log('result: ' + x));

执行subscribe操作：

operator就是map operator的wrapper：

此处调用source Observable实例的subscribe方法：

原始的Observable就是调用了range之后生成的Observable对象：

调用下一个Observable：

即map operator的实现：

再由map operator传递给下一个subscriber：

于是就执行到了应用程序指定的subscribe回调里：

随机文章
Javascript知识点必读
最近更新