寫一段簡(jiǎn)單的代碼來測(cè)試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);

執(zhí)行結(jié)果：

逐一分析：

subscribeToArray是一個(gè)函數(shù)，它接收一個(gè)array，生成另一個(gè)函數(shù)。第二個(gè)函數(shù)接收一個(gè)輸入?yún)?shù)subscriber，函數(shù)體內(nèi)依次調(diào)用next和complete方法處理array的內(nèi)容。

如下圖所示，觀察第二個(gè)函數(shù)是如何接受subscriber對(duì)象并產(chǎn)生輸出的：

當(dāng)然支持輸入為多重?cái)?shù)組：

輸出：

更多Jerry的原創(chuàng)文章，盡在：“汪子熙”:

總結(jié)

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

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