寫一段簡單的代碼來測試subscribeToArray:

test1(){const subscribeToArray = (array) => (subscriber) => {for (let i = 0, len = array.length; i < len; i++) {subscriber.next(array[i]);}subscriber.complete();} ;console.log(subscribeToArray);const input = [1, 2, 3];const result = subscribeToArray(input);const print = (a) => {if(!!a){console.log('next: ' + a);}else{console.log('completed!');}}const mySubscribe = {next: print,complete: print};result(mySubscribe);

執行結果：

逐一分析：

subscribeToArray是一個函數，它接收一個array，生成另一個函數。第二個函數接收一個輸入參數subscriber，函數體內依次調用next和complete方法處理array的內容。

如下圖所示，觀察第二個函數是如何接受subscriber對象并產生輸出的：

當然支持輸入為多重數組：

輸出：

更多Jerry的原創文章，盡在：“汪子熙”:

總結

以上是生活随笔為你收集整理的rxjs of操作符里subscribeToArray的实现原理示意图及分析的全部內容，希望文章能夠幫你解決所遇到的問題。

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