Rxjs 里 subscribeToArray 工具函数的详细分析
生活随笔
收集整理的這篇文章主要介紹了
Rxjs 里 subscribeToArray 工具函数的详细分析
小編覺得挺不錯的,現在分享給大家,幫大家做個參考.
subscribeToArray 函數體的邏輯：它的實質是一個函數：
該函數接收一個 array 作為輸入參數，遍歷這個 array，將其每個元素，作為另一個匿名函數執行的一部分。該匿名函數體內，將 array 的元素作為 subscriber 訂閱函數的輸入：
對上述代碼進行一點增強：
<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>在調試器里查看 newFunction，發現第12行代碼調用 subscribeToArray，輸入的 aInput，已經維護到新函數的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，也就不難理解其邏輯了：
直到應用程序代碼調用 Observable 的 subscribe 方法時，才會變量 input 數組，用 subscribe 的 next 方法依次處理 input 數組的元素。在 CombineLatest Operator 的例子里，input 元素就是 Observable 對象的組合。
更多Jerry的原創文章，盡在：“汪子熙”:
總結
以上是生活随笔為你收集整理的Rxjs 里 subscribeToArray 工具函数的详细分析的全部內容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： Rxjs Observable.pipe
- 下一篇： 基于stm32的超声波测距报警系统（附源