源代碼：

ngOnInit(): void {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));}

入口：

由此可見，scan的第二個參數可以用來傳入seed：

scan執行完之后，返回到pipe函數執行中，pipeFromArray(operations)(this)會執行scan函數返回的新函數，

即：scanOperatorFunction

創建新的scanOperator：

scan.js內部會創建一個新的Observable，將原始的Observable維護在source字段里：

然后執行應用代碼中的subscribe：

此處執行operator，即scan操作：

首先調用range.js里的next方法，逐一生成間隔：

這里再次看到了const source$ = range(0, 10)語句的惰性生成值效果：在range方法返回的Observable對象沒有調用subscribe方法之前，根本不會有任何整型值生成的行為發生。

從range.next調用執行到scan的accumulator方法體內：

此處進入了我們應用程序實現的accumulator方法：

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

總結

以上是生活随笔為你收集整理的rxjs里scan operator的执行研究的全部內容，希望文章能夠幫你解決所遇到的問題。

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