rxjs of操作符传入数组的单步执行
生活随笔
收集整理的這篇文章主要介紹了
rxjs of操作符传入数组的单步执行
小編覺得挺不錯的,現在分享給大家,幫大家做個參考.
源代碼:
const a = of([1, 2, 3]);const b = a.pipe(map((data) => {for( let i = 0; i < data.length; i++){data[i] = data[i] + 1;}console.log('data: ' + data);return data;} ));b.subscribe((data) => console.log('Fairy:' + data));最簡單的情況,沒有涉及到scheduler,故進入ELSE分支:
fromArray只是簡單的新建一個Observable對象:
subscribeToArray的實現:
Observable構造函數接收一個函數作為subscribe的回調函數。我們這個例子,subscribe回調函數通過subscribeToArray構造:
將subscribe函數保存到私有變量this._subscribe里:
更多Jerry的原創文章,盡在:“汪子熙”:
總結
以上是生活随笔為你收集整理的rxjs of操作符传入数组的单步执行的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: node_redis 中文文档及node
- 下一篇: rxjs of操作符生成的Observa