源代碼：

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的第二個參數(shù)可以用來傳入seed：

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

即：scanOperatorFunction

創(chuàng)建新的scanOperator：

scan.js內(nèi)部會創(chuàng)建一個新的Observable，將原始的Observable維護(hù)在source字段里：

然后執(zhí)行應(yīng)用代碼中的subscribe：

此處執(zhí)行operator，即scan操作：

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

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

從range.next調(diào)用執(zhí)行到scan的accumulator方法體內(nèi)：

此處進(jìn)入了我們應(yīng)用程序?qū)崿F(xiàn)的accumulator方法：

要獲取更多Jerry的原創(chuàng)文章，請關(guān)注公眾號"汪子熙":

總結(jié)

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

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。