rxjs5

1熱度

2回答

我有一個Angular 2服務連接到Angular Http服務，使用Rxjs 5連接到一個寧靜的web服務。 getObjects調用只是以有意義對象的Observable數組的形式返回解析的Json。我一直試圖讓我的模擬Http響應返回observable來解決，但我還沒有真正找到一個工作的答案。測試代碼： import { getTestBed } from '@angular/core/

2熱度

1回答

Conditional Observable.forkJoin（）building

基於我想構建forkJoin（）方法的函數的參數。例如：如果參數1是空=>不把一個http請求爲它 forkJoin（）內如果參數2爲空=>不把一個http請求它的forkJoin（）內代碼： getAllByIds(parameter1: any, parameter2: any) { let itemList = new Array(); return Obs

1熱度

1回答

如何解決多個觀察對象

我有2個（或更多）從服務返回的觀察對象，他們每個人只返回一個值（想想Observable.just()）。他們每個人都是不同的類型（我正在寫TypeScript，所以類型很重要）。有沒有辦法知道所有Observables何時解決（使用Promise術語）成功或失敗，我需要能夠單獨處理失敗，並繼續。人爲的例子： const obs1 = someService.getThisThing(); /

2熱度

1回答

如何通過`.publishReplay（）`緩存設置RxJS Observable超時？

我創建了一個Observable，在一段時間內緩存它們的結果。這個例子很好，非常有用！但我無法爲物品製作者設置超時時間。我試圖在mockDataFetch()中使用超時運算符，但在第一個失敗項目後，流無法恢復。如何通過超時實現mockDataFetch？這正是我所做的： const Observable = Rx.Observable; var counter = 1; var upda

-1熱度

2回答

Angular2 Observable not triggering rerendering

TLDR：直到用戶執行操作（例如，單擊按鈕）時，可觀察對象纔會觸發組件重新渲染。我正在更新由組件內注入的服務中包含的BehaviorSubject支持的observable。在我的組件中，我使用簡單的*ngIf="myObservable$ | async"來顯示div。我設法複製2分的情況下，一個工作，一個是不，但我不明白有什麼區別： //CASE 1 this._mySubject$.

5熱度

1回答

如何檢測變量的變化？

我有一個全局範圍的變量，我需要定期檢查變化。這是我會怎麼做簡單的JS： let currentValue, oldValue; setInterval(()=>{ if(currentValue != oldValue){ doSomething(); } }, 1000) 如何使用Observables它做了什麼？

1熱度

1回答

如何檢測承諾價值的變化？

我想輪詢一些返回promise的函數並檢測解析值的變化。我需要以某種方式在此添加interval運算符。 const observer = (newValue) => { console.log('Change detected', newValue); } Observable.fromPromise(getValue()) .distinctUntilChanged(

0熱度

1回答

Rxjs越來越AjaxObservable而不是Ajax響應

我的下一個可觀察我想篩選獲得的網絡，但.mapTo用戶（手機=> verifyPhoneInNetwork（電話，國家））返回，而不是Ajax響應AjaxObservable function verifyInNetwork(contacts: any, country: string) { const inNetworkOb = Observable .from(contac

0熱度

1回答

爲了維護秩序，連接所有RxJS運營商？

我有以下rxjs可觀察到的鏈： ngOnInit() { this.route.params.map(params => params['userAccountToken']) .switchMap(userAccountToken => this.userAccountService.activateAccount(userAccountToken)) .swi

14熱度

3回答

如何在angular2中使用rxjs實現對輸入keyup事件的反跳服務

我正嘗試調用輸入鍵盤事件上的服務。的HTML <input placeholder="enter name" (keyup)='onKeyUp($event)'> 下面是onKeyUp()功能 onKeyUp(event) { let observable = Observable.fromEvent(event.target, 'keyup') .map(value