system.reactive

0熱度

1回答

如何將需要OnError和OnCompleted的方法轉換爲Observable

對此，可能有一個非常簡單的答案，但我的大腦無法正常工作。我有一個方法，我需要調用一個不可察覺的框架，它具有以下模式。 client.GetAsync<TResult>( string resource, Action<Exception> onError, Action<TResult> onCompleted); 我需要將其轉換爲等待結果的同步操作。我想通的R

5熱度

2回答

如何在ConcurrentQueue或ConcurrentStack中使用IObservable/IObserver

我意識到，當我嘗試使用多個線程處理併發隊列中的項目時，多個線程可以將項目放入其中，理想的解決方案是使用Reactive Extensions與併發數據結構。我原來的問題是： While using ConcurrentQueue, trying to dequeue while looping through in parallel 所以我很好奇，如果有什麼辦法可以有作爲的項目投入它會連續出列一

3熱度

1回答

無擴展內存使用

我在使用無擴展的.NET WPF應用程序下面的代碼： public MainWindow() { InitializeComponent(); var leftButtonDown = Observable.FromEvent<MouseButtonEventArgs>(this, "MouseLeftButtonDown"); var leftButtonUp

1熱度

1回答

是否可以使用完整.NET框架的運行時運行Silverlight代碼？

要與持續集成的當前系統集成，我們希望使用NUnit來測試（非UI）Silverlight代碼。這樣做意味着使用完整的.NET框架的運行時執行Silverlight代碼，只要不實際使用Silverlight特定的類（如可視元素或DependencyObject），該框架通常工作得很好。但是，一些通用庫（例如Silverlight的Reactive Extensions）似乎也依賴於Silverlig

0熱度

1回答

linq語法如何在Rx框架中的IQueryable接口上工作

我已經開始關注反應框架。非常好的東西。但在查看代碼示例時，它讓我感到困惑。 linq語法適用於IQueryable。我認爲linq只適用於IEnumerable。關於C＃編譯器基於它的linq擴展方法轉換是什麼？它是否需要一組具有特定接口的方法？

1熱度

1回答

如何在Reactive Framework流中組合中間事件？

我對Rx還是比較新的，並且很難弄清楚如何表達這個（看似）簡單的訂閱。我在尋找這樣的事情：開始：InTransaction.Where（在inTransaction =>在inTransaction）如果：ItemChanged或在FlagChanged，讓改變=真結束：InTransaction.Where（在inTransaction =>！inTransaction）以上都是可觀察的。

2熱度

1回答

從Reactive Extensions（Rx）中的不同線程觸發OnNext不禮貌嗎？

當你自己實現IObserver時，你知道你將如何處理OnNext從不同線程中併發地或順序地被調用的情況，但是當涉及到這個時，內置Reactive Extension原語的期望是什麼？例如，將BufferWithTime應用於從多個線程調用的OnNext？從多個線程同時調用？

0熱度

1回答

在Reactive Extensions庫中使用Subject類的幫助

我正在嘗試使用一對Subject類來釋放2組事件序列。該應用程序是一個繪圖應用程序，其中一個主題在用戶點擊時觸發onNext，而另一個主題在用戶雙擊時觸發OnNext。我寫了GetClick & GetDoubleClick方法返回上述情況的可觀察性，並且似乎工作正常。下面的代碼中的問題是，如果在第一個主題上調用onNext來觸發點擊序列，則雙擊可觀察事物將永遠不會被調用。如果我在第一個主題上

13熱度

1回答

反應性擴展的殺手鐗？

Reactive Extensions（適用於.NET或JavaScript）的殺手級優勢是什麼？開發人員爲什麼要學習和使用它們？

0熱度

1回答

如何創建一個通知單實例<T>？

使用Rx，有沒有簡單的方法來創建一個單一的Notification<T>？最近我已經能夠找到的是： T value = ..; var notifyValue = EnumerableEx.Return(value).Materialize().First(); 這似乎相當迂迴。 Notification<T>的構造函數不可訪問，但是有沒有我不知道的工廠方法？