rxjs5

3熱度

1回答

當我一直在尋找通過我碰到這個功能跌跌撞撞rxjs庫： export function map<T, R>(this: Observable<T>, project: (value: T, index: number) => R, thisArg?: any): Observable<R> { if (typeof project !== 'function') { throw

2熱度

1回答

在處理多個項目後在RxJS中運行單個操作

我對RxJs比較新，在處理使用switchMap運算符發出的多個項目後無法鏈接單個操作。場景：使用後端數據爲下拉列表生成對象數組，然後鏈接單個操作以設置下拉列表的選定值。下面是有助於說明問題的非工作代碼。 this.sub = this.dataService.getUserData() .switchMap((data) => Observable.from(data)) // c

1熱度

1回答

如何使用.distinct通過一個對象屬性的內容從一個數組中刪除對象

我想了解我的用例的.distinct操作：通過用戶輸入我做的是一個國家的搜索並且只想在名爲country的屬性中僅顯示具有特定內容的一個對象。說明：我有各種物體的內容的BehaviorSubject： [ {id:1, country: "United Kingdom", city:"London"}, {id:2, country: "United Kingdom", city:"Ma

0熱度

1回答

錯誤的角度和RXJS承諾

我期待從2角一個應用程序升級到4，我發現了以下錯誤： Type 'Promise<void | Store>' is not assignable to type 'Promise<Store>'. 類型「無效|商店'不能分配鍵入'存儲'。類型'void'不可指定爲'Store'類型。有問題的線路是這樣的： return this.http.get(url, { headers: this

1熱度

3回答

rxjs5合併和錯誤處理

我想合併/合併多個觀察對象當他們每個完成時執行一個最後函數。 merge運營商似乎並行執行每個訂閱，這是我需要的，但如果他們中的任何一個拋出一個錯誤執行被暫停。 RxJS 4版有一個運營商mergeDelayError應該繼續執行，直到所有的人都完成了所有訂閱，但該運營商不版本5實現。我應該回到不同的操作員嗎？ var source1 = Rx.Observable.of(1,2,3).dela

1熱度

2回答

使用forkJoin的打字稿打字錯誤

使用forkJoin操作員窗體RxJS時，遇到TypeScript類型檢查失敗。這是有問題的代碼： let products = this.http.get(productUrl, { headers: this.headers }) .map(response => response.json().data as Product[]); let loans = Obs

4熱度

2回答

RxJS combineLatest operator怪異行爲

我有一個關於RxJS combineLatest操作符的查詢。我已經修改了在 https://www.learnrxjs.io/operators/combination/combinelatest.html 給出的示例如下： //timerOne emits first value at 1s, then once every 4s const timerOne = Rx.Observable

1熱度

1回答

observable forkjoin永遠不會執行可觀察的angular2

我試圖使用forkJoin執行多個XHR請求（在getImages函數中），每個請求都包含在可觀察對象（在getImage函數內）中。然而，沒有任何請求被執行，即從不執行observer.next()。我曾嘗試使用zip而不是forkJoin，但這也不起作用。我確信我可以在我創建的所有觀察對象上都有complete。 getImages(urls: string[]) { Observa

0熱度

1回答

如何在RxJs 5中將項目分組爲大小爲n的組？

我需要幫助將無限數據流上的項目分組而不會丟失數據。組的大小必須不大於n個元素。如果在一段時間內沒有物品出現，那麼當前組的大小可能小於n。試圖驗證碼： Observable.create(observer => { setTimeout(() => observer.next([1]), 90) setTimeout(() => observer.next([2, 3])

1熱度

1回答

返回從rxjs/Subject（Observable.from vs Observable.of）數組的觀測值

我正在使用WebSockets與後端WebApi進行通信。一切工作正常，除了我不能從我的服務返回我的自定義對象。我正在使用Angular 4.3.4和rxjs 5.4.3。 //ngInit from my component ngOnInit() { this.modelsSubscription = this.mainService.getModels().subscribe(m