Rxjs 里 subscribeToArray 工具函数的详细分析
生活随笔
收集整理的這篇文章主要介紹了
Rxjs 里 subscribeToArray 工具函数的详细分析
小編覺得挺不錯的,現(xiàn)在分享給大家,幫大家做個參考.
subscribeToArray 函數(shù)體的邏輯：它的實質(zhì)是一個函數(shù)：
該函數(shù)接收一個 array 作為輸入?yún)?shù)，遍歷這個 array，將其每個元素，作為另一個匿名函數(shù)執(zhí)行的一部分。該匿名函數(shù)體內(nèi)，將 array 的元素作為 subscriber 訂閱函數(shù)的輸入：
對上述代碼進行一點增強：
<html> <script> const subscribeToArray = (array) => (subscriber) => {for (let i = 0, len = array.length; i < len && !subscriber.closed; i++) {subscriber.next(array[i]);}subscriber.complete(); };const aInput = [1,2,3,4];const newFunction = subscribeToArray(aInput);debugger; </script> </html>在調(diào)試器里查看 newFunction，發(fā)現(xiàn)第12行代碼調(diào)用 subscribeToArray，輸入的 aInput，已經(jīng)維護到新函數(shù)的Closure(閉包)里了：
這個 newFunction 應該怎么消費呢？
<html> <script> const subscribeToArray = (array) => (subscriber) => {for (let i = 0, len = array.length; i < len && !subscriber.closed; i++) {subscriber.next(array[i]);}subscriber.complete(); };const aInput = [1,2,3,4];const newFunction = subscribeToArray(aInput);const subscriber = {closed: false };subscriber.next = (data) => console.log("next: " + data); subscriber.complete = () => console.log("completed!"); debugger;newFunction(subscriber); </script> </html>輸出：
回到 fromArray.js 的 subscribeToArray，也就不難理解其邏輯了：
直到應用程序代碼調(diào)用 Observable 的 subscribe 方法時，才會變量 input 數(shù)組，用 subscribe 的 next 方法依次處理 input 數(shù)組的元素。在 CombineLatest Operator 的例子里，input 元素就是 Observable 對象的組合。
更多Jerry的原創(chuàng)文章，盡在：“汪子熙”:
總結
以上是生活随笔為你收集整理的Rxjs 里 subscribeToArray 工具函数的详细分析的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： Rxjs Observable.pipe
- 下一篇： 用 SAP ABAP 编写的俄罗斯游戏