reactive-extensions-js

3熱度

1回答

我有兩個行爲主題流，我試圖forkJoin沒有運氣。正如我想象的那樣，它給出了它的最後兩個值。這可能以某種方式實現它嗎？它不在主題後面調用。 let stream1 = new BehaviorSubject(2); let stream2 = new BehaviorSubject('two'); Observable.forkJoin(stream1, stream2) .s

10熱度

2回答

RxJs：輪詢，直到間隔進行，或者正確的數據接收

我如何與RxJs的瀏覽器中執行以下情形：提交數據排隊等候處理取回作業ID 調查另一個端點每1秒，直到結果可用或60秒已通過（再失敗）中級解決方案，我想出來的： Rx.Observable .fromPromise(submitJobToQueue(jobData)) .flatMap(jobQueueData => Rx.Observable .

0熱度

1回答

在可觀察的數組中增加單獨的值 - RxJS

我一直在試圖解決這個問題一段時間了，我猜這是一個相當普遍的問題，但我想要做的是增加來自觀察到，並增強與觀察或promiselike 發生所以我想類似如下： function augment(person: Person): Observable<PersonWithAddress> { // does ajax call or something } const items$: O

4熱度

1回答

RxJS間隔無延遲

下面的代碼發出5000ms後int，然後又在每一個5000ms後： let evens = Observable.interval(5000) .map(i => { return i * 2; }); evens.subscribe((i) => { console.log(i); }); 是否有可能做到這一點，但馬上有第一個結果（0ms

1熱度

2回答

將多個Observable與不同的操作/操作結合

我正在構建一個Angular2應用程序，所以我習慣了Observables和Reactive Extensions作爲一個整體。我正在使用TypeScript和rxjs。現在我已經有了一個可觀察的，或者如果你願意的話，一些對象的數組。讓我們說個人對象。現在，我已經有了人，畫線的其他兩個流，並希望這些，所以我得到一個流這始終是最新的組合： var people$ = getPeople();

2熱度

1回答

如何在rx.js中使用bufferWithCount創建第一個項目？

說你做這樣的事情： Rx.Observable.range(1, 5).bufferWithCount(2, 1).subscribe(console.log); 這將返回： [1, 2] [2, 3] [3, 4] [4, 5] [5] 我想對於結果看起來像（基本上迫使第一個值發射）： [<userDefined>, 1] [1, 2] [3, 4] etc...

2熱度

2回答

combineAll不空數組

JSBIN Sample 上發射我有一個可變集的子組件（POJO對象），每個具有其自己的狀態流。每次用戶觸發addChild/removeChild/clearChildren時，都會使用#switchMap發送一組新的子狀態流。到現在爲止還挺好！（和RxJS一樣驚訝！）與Rx.Observable.from(arrayOfStateStreams).combineAll()只要arrayOf

0熱度

2回答

RxJS/ReactiveX正確的模塊通信

我很新的反應編程，但已經戀愛了。然而，我的大腦仍然很難轉向它。我試圖按照「避免使用主題」和「避免不純的功能」以及「避免命令式代碼」的所有建議。我發現很難實現的是簡單的交叉模塊通信，其中一個模塊可以註冊「action」/ observable，另一個可以訂閱並對其作出反應。一條簡單的消息總線可能會工作，但這會強制使用主題和我試圖避免的命令式代碼風格。因此，這裏是一個簡單的出發點，我用打： //

0熱度

1回答

嵌入式查詢人口RxJs

我無法弄清楚如何解決以下問題。有對象類型： Box { Fruit[n]: { Kinds[n]: { id: string; name: string; } } } 我fuits的箱子從API調用作爲可觀察到的（Angular2）水果[]然後，我想與其他填充它的「導航屬性」 API呼叫什麼回饋一個觀察，以及像這樣： Bo

3熱度

2回答

RxJS 5任務隊列，如果任務失敗則繼續

想象一下，我們有一個觸發AJAX請求的HTML頁面。我們希望確保AJAX請求按順序執行。直到前一個AJAX請求完成或發生錯誤，下一個AJAX請求才會被觸發。我試圖通過使用RxJS concatMap的任務隊列對此進行建模。每個AJAX請求都被建模爲Observable。如果AJAX請求成功完成，一切都很好，但是如果錯誤發生，那麼隊列中的下一個任務就不會執行。下面是一個例子，使用setTimeo