rxjs5

2熱度

2回答

例如，假設我想進行一些API調用。我正在處理的api很容易出現競爭狀況，所以如果我在同一時間更新服務器上的同一條數據時發出3個api調用，它可能會丟失一些數據。因此，我想排隊我的請求，然後在發出下一個請求之前開啓等待響應返回。基本上我需要類似concatMap的東西，但concatMap的問題是它同時觸發所有的請求。我需要concatMap在發射下一個請求之前等待。我正在使用rxjs 5. 這

0熱度

1回答

如何確保Angular服務構造函數中的異步初始化完成？

專家請告訴我如何在調用類中的其他函數時確保服務構造函數中的異步初始化完成？ constructor() { var sock = new SockJS(this._chatUrl); this.stompClient = Stomp.over(sock); this.stompClient.connect({}, function() { });

3熱度

1回答

史詩不會對來自另一史詩的行動作出反應

我有一個redux-observables的問題。在我的情況下，史詩般的等待結束另一部史詩。第二部史詩可以從緩存發出請求或返回數據。當第二個請求全部按預期工作時，但當它返回緩存時，第一個不會繼續。 const { Observable } = Rx; const FETCH_USER = 'FETCH_USER'; const FETCH_USER_FULFILLED = 'FETCH_U

0熱度

1回答

執行邏輯時RxJS 5的refcount（）從源

連接到或取消訂閱按照RxJS 5手冊關於Multicasting ...我們可以使用ConnectableObservable的引用計數（）方法（參考計數），它返回部一個可以跟蹤它擁有多少用戶的Observable。當用戶數量從0增加到1時，它會爲我們調用connect（），這會啓動共享執行。只有訂戶數量從1減少到0時，它纔會完全取消訂閱，停止進一步執行。我想了解是否有可能鉤到這些事件，並執行一

3熱度

2回答

組合/合併可觀察對象

假設我正在開發一個聊天應用程序。我觀察到的threads$發出每ň秒線程的陣列，觀察到offline$當一個線程下線成爲了通知，可觀察online$當一個線程成爲網上通知： enum ConnectionStatus { Offline = 0, Online } interface Thread { id: string; status: ConnectionStatus

3熱度

1回答

有沒有辦法知道rxjs websocket是否打開

我在一個角度4的項目中使用RxJS。我試圖啓動一個WebSocket，特別是要知道什麼時候這個打開。我目前使用RxJS（v5）的WebSocket。 https://github.com/ReactiveX/rxjs/blob/master/src/observable/dom/WebSocketSubject.ts 我注意到WebSocketSubjectConfig中有一個openObse

1熱度

2回答

如何使用RxJS從arrayBuffer拆分數據框？

我使用websocket從硬件接收數據幀。數據幀的定義如下： 0xbb(head) ---data--- 0xee(tail) 所接收的數據是存儲在Uint8Array，可以存在多個幀： var buffer = new Uint8Array([0xbb,0,0,0,0xee,0xbb,1,1,1,0xee,0xbb,3,3,3,0xee]); ，我可以在陣列轉換爲可觀察到的： var ob

0熱度

1回答

在Rx.js中，我怎樣才能區分哪個流觸發combineLatest方法？

我正在寫我自己的版本who to follow?。點擊refreshButton將獲取建議列表並刷新<Suggestion-List />，並且closeButton將從建議列表中重新提取數據並刷新<Suggestion-List-Item />。我想讓closeClick $和suggestions $結合在一起來駕駛用戶。這裏演示代碼： var refreshClick$ = Rx.Obs

0熱度

2回答

Observable.next（）休息循環

這段代碼解析三元組（不是那麼重要），並且應該一次返回一個停車位。問題在於調用observer.next（）會中斷循環，因爲它只運行一次。 console.log也不會被調用。我可能錯過了一些東西，但有可能observer.next（）打破循環？有沒有錯誤，或者它是一個功能，或者我只是明顯錯誤？ return Observable.create(observer => { this.fet

1熱度

1回答

RxJS：鏈式觀察量不使用相同的根可觀察值

我正在嘗試學習RxJS，並試圖構建我認爲是一個簡單而直接的示例。創建一個間隔生成的隨機數的可觀察值，然後根據該可觀察值使用另外兩個可觀察值來跟蹤已經看到的最低值和最高值。 rStStream似乎表現得像預期的一樣，minStream和maxStream都顯示正確跟蹤。我遇到的問題是，當執行它時，似乎rngStream，minStream和maxStream在每個時間間隔上都有不同的隨機數。我試圖了