system.reactive

0熱度

3回答

可觀察到的序列

我有一些可觀察到的順序執行所有觀察員後完成操作，例如： var period = TimeSpan.FromSeconds(0.5); var observable = Observable .Interval(period) .Publish() .RefCount(); 我想在後臺線程上執行一些艱苦的計算該序列的元素，並進行一些最後的動作當所有的計算完成時。

c# system.reactive observable 2017-02-16

---

1熱度

2回答

緩衝組按組進行反應擴展，嵌套訂閱

我有一個事件源生成屬於某些組的事件。我想緩衝這些組並將這些組（批量）發送到存儲。到目前爲止，我有這個： eventSource .GroupBy(event => event.GroupingKey) .Select(group => new { group.Key, Events = group }) .Subscribe(group => group.Events

c# .net system.reactive reactive 2017-02-24

---

2熱度

1回答

rxcpp簡單可觀察<int>

我在C＃中使用RX進行編程，現在我想用C++中的rxcpp進行編程。 我正在嘗試做最簡單的事情，定義一個類成員變量observable<int>。 問題是，observable被定義爲： template<class T, class SourceOperator> class observable 什麼是SourceOperator？ 如何定義簡單的observable<int>？ 當尋找

c++ system.reactive reactive-programming rxcpp 2017-02-26

---

0熱度

2回答

Rx - 與超時有區別嗎？

我想知道有沒有什麼辦法可以實現Distinct in Reactive Extensions for .NET，這樣它就可以在給定的時間內工作，在這段時間之後它應該重置並允許再次返回的值。我需要這個在應用程序中的熱門應用程序，現在停止工作一整年，所以我擔心性能，我需要一段時間後允許這些值。還有DistinctUntilChanged，但在我的情況下，值可以混合使用 - 例如：A A X A，Dis

c# .net timeout distinct system.reactive 2017-02-26

---

1熱度

1回答

心跳圖，使用無功擴展

考慮一個簡單的場景： A和B是在一個房間裏，給B.一個談判房間是黑暗和B無法看到A.怎能B圖出來，如果A是暫停或A被從房間綁架？ 當A會話時，A提供IObservable 對話 B後來訂閱Talk.Subscribe（string =>處理什麼A說）。 B可以同時訂閱Observable.Interval 心跳作爲心跳檢查。 我的問題是運營商所應該使用合併/組合兩個的IObservable，這樣，

c# system.reactive .net-4.6 .net-4.6.1 2017-02-27

---

1熱度

1回答

訂閱布爾狀態使用Rx

我有一個IObservable<bool>，我希望在最後一個n項目設置爲true時得到通知。 對於像我想要的東西： MyBool.Buffer(10).SelectMany(x => x).All(x => x).Subscribe(x => /*do something*/); 但它只能觸發一次;似乎OnCompleted被解僱了。

c# system.reactive 2017-02-27

---

0熱度

2回答

將IObservable傳遞給構造函數 - 好主意？

我看了這個網站上有關如何使用的IObservable是說comment .. 作爲一般規則（準則），我強烈建議不具有IObservable<T>作爲參數的方法。如果該方法是新的Rx操作員，例如Select,MySpecialBuffer,Debounce等 所以我一直在嘗試將這個建議應用到我的代碼，並繼續運行到打破此規則似乎很方便的情況。看看下面的代碼，並比較PersonSelectorViewM

system.reactive 2017-03-03

---

1熱度

2回答

使用的GroupBy用的毗連只返回第一組值

我有作爲的GroupBy預計該工程的一些測試代碼... 代碼 var sw = Stopwatch.StartNew(); int groupSize = 5; var coreObservable = Observable .Range(1, 20) .Select((x, idx) => new { x, idx }) .GroupBy(x => x.idx

c# system.reactive 2017-03-03

---

5熱度

1回答

自定義Rx運算符只有當有一個最近的價值

我想創建一個Rx運算符，似乎很有用，但我已經驚訝地發現沒有任何問題在Stackoverflow匹配。我想在Throttle上創建一個變體，如果有一段時間不活動，可以立即讓數值通過。我想象的用例是這樣的： 我有一個下拉菜單，當數值發生變化時會啓動web請求。如果用戶按住箭頭鍵並迅速循環顯示值，我不想爲每個值啓動一個請求。但是如果我對流進行節流，那麼用戶每次只需以正常方式從下拉列表中選擇一個值，就必須

c# system.reactive 2017-03-03

---

0熱度

1回答

如何ReactiveX

合併兩個布爾可觀察最近，其中Rx工作，我在與合併兩個觀測，並試圖從他們作出命令的麻煩。 我有兩個觀測，所以我想從他們做出的命令，並且命令可以執行應該是真實的只有在這些觀測都是如此。這裏是我的代碼： BuyCommand = playerData.Gold.Select(x => x >= boosterStoreItem.price) .Merge(inventoryItem.Can

c# unity3d system.reactive 2017-03-05

---