rxjs

3熱度

1回答

在組件的負載上，我訂購了一個數組數組，並在List和Drop Down中顯示相同的數組，並且工作正常。然後我添加了「添加按鈕」，它將一個對象添加到數組中，並在列表中顯示相同的內容。問題就像是即使當我從訂閱退訂即使如此，它是增加當我點擊添加按鈕的值，可以在任何請讓我知道爲什麼發生這種情況 Plunker：https://embed.plnkr.co/CoZCakFsx5q8GBWDBZ24/ 下

0熱度

1回答

RXJS可觀察到的缺失定義

我在Visual Studio代碼中創建了一個新的AngularCLI項目。然而，我使用的是rxjs Observables，與另一個AngularCLI項目相比，Observable缺少很多定義。這兩個項目都使用rxjs 5.4.2版本。我的新AngularCLI項目僅顯示Observable的3個定義，並在node_module \ rxjs \ add \ operator中查找這些定義。但

0熱度

2回答

startWith（）返回主題

我想使用默認值的主題發出值。 startWith("def")是此方法。 subject = new Rx.Subject().startWith("def value"); 不幸startWIth回報Observable，所以我不能使用onNext()，這是我使用的首位主題的唯一原因。這個問題的解決方法是什麼？ subject.onNext("next val"); //cannot cal

-1熱度

1回答

關於相同功能的開關圖

我不是rxjs的專家。我有一個方法，實際上保存。 this.saveProducts(this.boxes, 'BOXES') 但還有另外兩種不同類型的項目需要使用相同的方法進行保存，只是參數不同而已。 this.saveProducts(this.containers, 'CONTAINER') 在我的組件中，我幾乎沒有其他的獨立存儲正在發生，所有這些都應該發生一個一個。所以我的方法

1熱度

1回答

如何從組件中獲取服務中Observable的值並將其傳遞給我的視圖？

我爲此嘗試了很多事情，似乎沒有任何幫助。我試圖做到：用戶點擊選擇組件視圖事件觸發按鈕，選擇組件上調用changePage() 此呼籲服務changePage()並傳遞在一個字符串中 changePage()在服務更新中observable 在主成分，subscription被創建並且基於在服務Observable的可變pageName值的pageName更新爲頁面服務上的報頭 impo

1熱度

1回答

可觀察訂閱 - 忽略下一個方法

我不想在next()方法上做任何事情，我想要處理error()和complete()。這是我的作品以及當前的解決方案： this.myService.myServiceObservable(params) .subscribe( () => { /**/ }, error => { // Handling errors here

0熱度

2回答

如何爲對象創建行爲主題並在另一個組件上訂閱它？

我在服務類中創建了一個行爲主題。 public personObject: BehaviorSubject<any> = new BehaviorSubject<any>({ personId: 1, name: 'john doe' }); 在一個導入這項服務的組成部分，我已經訂閱此行爲主體是這樣

0熱度

1回答

如何在使用redux-observables時正確地排列動作的時間

我正在嘗試創建一個Epic來排列要分派的動作，在這種情況下，這些動作是要使用快捷欄顯示的消息，例如，三個錯誤幾乎同時發生，我想用SnackBar顯示三條錯誤消息，Epic應該調度一個動作來顯示第一個消息3秒鐘，然後顯示第二個消息3秒鐘，然後第三個消息顯示3秒鐘。另外，如果其中一個小吃店被關閉，應該顯示「隊列」中的第二個，等等。我現在正在做的是調度在Epics中顯示消息以捕獲錯誤的操作，然後我創建

0熱度

2回答

如何在數據發生變化時更新視圖

我想了解很多類似的東西：Typescript，Express和我的新「迷戀」REACT和RXJS。我創建了一個Quick-List on github研究這些東西，但我發現了一個問題... 「的反應數據發生變化時如何更新視圖」我上有一個對象「名單」類「IndexRoute」： import { NextFunction, Request, Response, Router } from "e

0熱度

2回答

使用foreach循環和Observable連接多個調用

我想鏈接多個請求到我從數組中獲取的url。在下一個鏈條之前，我想等待前一個完成。如果前面的失敗沒有關係。我試圖用forkJoin來做這件事，但我知道如果其中一個請求失敗，它會返回錯誤。 this.dataServers.forEach(dataServer => { observableBatch.push(this.getFoodsByQuery(dataServer.url, que