原始代碼：

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回調里：

要獲取更多Jerry的原創文章，請關注公眾號"汪子熙":

總結

以上是生活随笔為你收集整理的rxjs pipe和map组合的一个实际例子的单步调试的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。