rxjs5

-1熱度

4回答

我有一個使用角度的HTTP服務 @Injectable() export class MyService { constructor(private http: Http) { } getThings() { return this.http.get('url').map((res) => { // massage data here and ret

1熱度

2回答

如何鏈接RXJS中的承諾列表？

如何鏈接RXJS中的承諾列表？每一個承諾需要執行時，先前解決（工作todo是有狀態的）。我現在做它的方式原始的感覺： const workTodo = []; // an array of work const allWork = Observable.create(observer => { const next=() => { const currentTodo = w

1熱度

2回答

rxjs發出並行請求並等待兩個完成並更新後，其中一個發出

我的要求是，我有兩個端點一個列出HondaCars和一個列表PeugoetCars當我使用combineLatest運算符時，它不會等待另一個流完成; 這裏我的要求=>第一次等待，直到兩個源流兩者的一個後收到的值那麼刷新後接收的值編輯所以經過搜索的一段時間，我只是貼有combineLatest但訣竅是在這裏： this.loading = Observable.combineLatest(

1熱度

1回答

可觀察的計時器永遠不會完成儘管takeUntil

我有很多痛苦的理解，爲什麼我的觀察從未完成。我的代碼應該是這樣的工作：初始化爲false 主題isTimerEnabled$這是switchMap倒是來，要麼返回Rx.Observable.never()時isTimerEnabled$發出假的，否則它映射到一個功能Rx.Observable.timer可觀察從計時器我take一切爲1秒。 1秒後，可觀測完成的問題是，當我訂閱了這一切，我的

-1熱度

1回答

Rxjs調用返回頁面中的數據的服務

我需要爲列表[「A」，「B」，「C」]中的每個項目調用Web服務。該服務將返回頁面中的數據（默認頁面大小爲100）。服務的第一次調用（使用page = 1作爲參數）將有記錄的總數設置爲響應中的標題，並基於我需要多次調用該服務。我需要等待所有調用的響應，才能繼續進一步的邏輯。任何指針來實現上述使用Rxjs將有很大的幫助

0熱度

1回答

如何正確調用/管理我的可觀察項的後續訂閱？

試圖創建一個可以推送給所有訂閱者的可觀察對象，但是我遇到了多個訂閱的問題。這是我的理解，訂戶管理是爲我自動處理的。在下面的例子中，我的目標是記錄'a'和'b'。 let observer = null as any; let ob$ = new Observable<any>(ob => { //this piece of code will be called twice, over

3熱度

1回答

讓潛在異步RxJS觀察到的肯定異步

有潛在異步觀察到，即是這樣的： const potentiallyButNotNecessarilyAsyncObservable = [ Observable.of('sync'), Observable.of('async').delay(100) ][Math.round(Math.random())]; potentiallyButNotNecessarilyAs

1熱度

2回答

concatMap可變數量的承諾和管道結果作爲下一個承諾的參數

我有一個可變數量的承諾，我想依次將前一個承諾的結果作爲下一個承諾的參數執行它們。目前，我設法Concat的，以便他們按順序執行它們： const promises = [p1, p2, p3, p4, ....]; const source$ = promises.map(p => Rx.Observable.defer(p)); const combination$ = Rx.Observa

0熱度

1回答

如何更改RxJS使用的默認調度程序？

據我所知在舊RxJS 4我可以更改默認調度程序猴修補DefaultScheduler.prototype。這是正確的，或者有更好的方法來做到這一點？這是可能實現在更新的RxJS 5。因爲正如我在源代碼中看到的那樣，它們使用null作爲默認調度程序，但不能進行猴子修補。例如here 那麼如何更改RxJS使用的默認調度程序？（用於測試，調試或只是爲了好玩）

3熱度

1回答

RxJS 5，轉換可觀察到一個BehaviorSubject（？）

我有可觀察到的，一旦它具有訂戶，將做查找一個父和發射一個單一的值，則完成了。我想那轉化爲可觀察到的（或行爲主體或任何作品），其執行以下操作：一旦它至少有一個用戶，它會從父觀察到的（一次）的結果。然後它將這個價值發放給它的所有用戶，並且當它們訂閱時也將這個單一價值發給所有未來的訂戶。即使用戶數減少到零，它也應該繼續這種行爲。看起來這應該很容易。這裏是沒有工作： theValue$: Observ