rxjs5

1熱度

1回答

我正在嘗試使用Observable.if來確定要分派哪個動作。在下面的情況下，我希望它發送SIGN_OUT。但是，它不派遣任何行動。如何正確使用它？由於 export const initEpic = (action$, store) => action$ .ofType(INIT) .mergeMap(() => Observable.if(

2熱度

1回答

爲什麼用戶在主題上聽到舊錯誤？

我有一個主題 const subj$$ = new Rx.Subject(); 和後期用戶 subj$$.next('value'); setTimeout(() => { subj$$.subscribe(console.log, console.error); }, 500); 預期沒有任何反應後500毫秒但是... 如果我把錯誤 subj$$.error('erro

4熱度

1回答

Rxjs，fromEvent來處理多個事件

什麼是處理在rxjs 5.1相同的DOM節點對多個事件的最好方法？ fromEvent($element, 'event_name')但我只能指定一次一個事件。我想處理scroll wheel touchmove touchend事件。

1熱度

2回答

RXJS - Observable.do無法正常工作

我試圖用do語句返回Observable。由於某種原因，不會調用do語句。任何幫助將appreicated： public addTarget(video: VideoFile, language?: Language): Observable<Language> { if (!this.isTargetCollectionDeclared(video)) { v

2熱度

1回答

RxJS Redux-Observables測試重試當在一個史詩

我正在努力如何測試retryWhen運營商在redux-observable epic。基於this example取自docs，我叉了this jsbin我試圖測試的情況下，響應失敗2次，之後，它返回一個有效的響應。以下是部分代碼。對於整個實施，請使用this jsbin let RetryStrategy = attempts => attempts .zip(Observable

1熱度

1回答

RxJS5 - combineLatest無法訪問Angular的本地屬性

我需要調用兩個http服務和一個套接字。第一個http調用是獲取元數據並在本地設置其中一個值。然後，我需要調用第二個http服務，它返回通過套接字更新後的初始值。這是我到目前爲止有： export class MyComponent implements OnInit { subscription: Subscription; title: string; prop

1熱度

2回答

處理Ajax請求 - 無極VS RxJs觀察到 - rxjs

我使用Rxjs觀測量來處理類似下面的嵌套的方式Ajax請求操作者的要求： Rx.Observable.fromPromise($.getJSON('list1.json')) .switchMap(function responseA(aResponse){ /* processing aResponse*/ if(aResponse.fileName){

4熱度

2回答

RxJS函數從一個observable發出最後一個值然後發出true

Hellow，我試圖創建存儲最後一項來自OBS的observable（OBS）和subject（SUB）的函數，而SUB具有F值和發射它（只有它）當孫換成T OBS ---a----b----c----d----e----f----g----h----- SUB ------F----------T------------F-------T----- OUT --------

1熱度

2回答

使用RxJs將多個回調返回到可觀察狀態

我目前正在使用RxJs開始嘗試定義返回observables的模塊。（每個模塊作爲黑匣子工作，只暴露其可觀察物）。我的主要問題是由於我正在使用的第三方庫：UWA：我所有的dom元素都是從UWA對象生成的，並觸發UWA「事件」。順便說一句我想將這些自定義事件映射到observables。這裏是事件數據結構的一部分： tabBar = *somecode*...{ .... on

0熱度

1回答

變量添加到一個變量可觀察<>

我有可觀察到的變量： messages: Observable<Message[]>; 我想變量添加到這個可觀測變量。由於這是信息的集合：消息[]，我要留言變量添加到它： const newMessage = new Message(objMessage); 我不知道如何做到這一點，我試過，但忽略了最低的工作，因爲它是沒有可觀察的變量： newThread.messages = [newM