system.reactive

0熱度

1回答

RXSwift，檢測重入異常

我在RXSwift初學者，我有問題，我的代碼 我有代碼： let dartScore = PublishSubject<Int>() dartScore.asObservable() .scan(501) { intermediate, newValue in let result = intermediate - newValue

swift xcode system.reactive rx-swift 2017-12-03

---

3熱度

1回答

Rx TestScheduler不能很好地處理返回和延遲

我無法爲包含Return和Delay的組合的observable編寫單元測試。問題是TestScheduler不會發出任何通知，無論提前多長時間。 var scheduler = new TestScheduler(); var input = new Subject<bool>(); var output = scheduler.Start(() => Observable.Re

unit-testing system.reactive 2017-10-16

---

2熱度

3回答

如何使用Observable或async/await包裝異步回調？

我正在使用與回調一起工作的網絡API。所以基本上，我有一大堆的方法調用，我需要這個第三方庫，像這樣使用： void SendNetworkRequest(string requestType, Action<Response> callback) 我找到的代碼變得有點古怪，因爲我所有的方法依賴於網絡來自第三方API的資源也需要自行實現回調。舉例來說，在我的主場景我可能想要得到的球員資料和我的代

c# asynchronous async-await system.reactive reactive-programming 2017-10-17

---

0熱度

2回答

收聽列表中項目內的可觀察事件

我有IObservable<ImmutableArray<T>>，其中每個T都有相應的Delete命令，IObservable<Unit>。我試圖在用戶單擊列表中的項目上的刪除時作出響應。當一個項目被添加到列表中時，我想要開始監聽（訂閱）Delete命令。當一個項目從列表中刪除時，我想停止收聽（取消訂閱）。如果一個項目X被添加到列表中，並且列表多次更改，我想確保我只在X上訂閱了刪除命令 - 當它被

c# system.reactive 2017-10-18

---

4熱度

3回答

RxJs將流拆分爲多個流

如何基於分組方法將永不結束的流拆分爲多個結束流？ --a--a-a-a-a-b---b-b--b-c-c---c-c-d-d-d-e...> 到這些觀測 --a--a-a-a-a-| b---b-b--b-| c-c---c-c-| d-d-d-| e...> 正如你所看到的，a是在開始的時候，我收到b

javascript rxjs system.reactive 2017-10-19

---

3熱度

1回答

在.NET標準庫中訪問調度程序IScheduler

This question描述如何確保IObservable<>.Throttle通過將UI調度程序傳遞到Throttle而在UI線程上運行。但是，我的觀察對象是在基於.NET Standard 1.5的共享庫中定義的。在.NET標準中是否有等效的DispatcherScheduler.Instance或者我應該從使用（WPF/UWP/etc）庫注入調度程序？

c# .net system.reactive .net-standard 2017-10-21

---

2熱度

1回答

RxSwift可觀察錯誤停止鏈 - 帶Rx的Web服務，如何恢復？

顯然我是RxSwift的新手，雖然我消耗了大量文檔和演講，但我想我缺少一些基本概念。 在我的應用程序中，我有一個REST風格的Web服務來加載各種資源，但Web服務的基礎URL在構建/開始時未知。相反，我有一個「URL解析器」Web服務，我可以使用我的應用程序包，版本和可能的環境（「生產」，「調試」或在應用程序調試設置中輸入的任何自定義字符串）調用以獲取基礎URL，然後使用爲實際的服務。 我的想法

json swift web-services system.reactive rx-swift 2017-10-28

---

0熱度

1回答

RX.net的DropQueue機制

我遇到了RX.net的背壓問題，我找不到解決方案。我有一個可觀察的實時日誌消息流。 var logObservable = /* Observable stream of log messages */ ，我想通過他們正在通過網絡發送之前，該串行從logObservable實時日誌消息的TCP接口暴露。所以，我做到以下幾點： foreach (var message in logObserva

c# c#-4.0 system.reactive reactive-programming reactive 2017-10-28

---

2熱度

1回答

爲什麼不能觀察，最後被調用？

我不理解Finally方法。在這種情況下它不會起火。 [TestMethod] public void FinallyHappensOnError() { bool finallyActionHappened = false; try { Observable .Throw<Unit>(new DivideByZeroException()

c# system.reactive 2017-11-10

---

0熱度

1回答

如何單元測試Rx.Net的foreach訂閱

所有消息應發佈到消息總線： upstream.Get().ForEachAsync(async e => await _bus.Publish(e, cancellationToken)); 我想單元測試來驗證publish方法被調用正確： [Theory, AutoMoqData] public void Publish_ShouldPublishAllDataSources(

c# unit-testing system.reactive rx.net 2017-11-11

---