前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >rxjs pipe和map组合的一个实际例子的单步调试

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

作者头像
Jerry Wang
发布2020-09-27 14:36:19
4030
发布2020-09-27 14:36:19
举报

原始代码:

代码语言:javascript
复制
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回调里:

本文参与 腾讯云自媒体分享计划,分享自作者个人站点/博客。
原始发表:2020-09-26 ,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 作者个人站点/博客 前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体分享计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档