system.reactive

    2熱度

    2回答

    我有一種情況,我希望對一個observable進行採樣,但給定了特定的條件,我想接​​受每個事件。這是我的嘗試,但我有一種感覺是不安全的,因爲它不斷重新註冊主序列。例如,如果採樣保持開啓和關閉狀態,主序列始終爲訂閱生成一個值,那麼我認爲我會一直得到重複的事件。 IObservable<T> SampleMaybe<T> (this IObservable<T> @this ,

    0熱度

    1回答

    我有一個服務,MyService,其中有一個方法getList()它返回一個可觀測項目的數組中,像 getList(): Observable<Item[]> 一旦清單中查找,然後將每個項目需要去通過第二種方法MyService,fillItem(Item)。這種方法發出返回一個無極一些後端的請求,是這樣的: fillItem(item: Item) { BackEnd.retrie

    0熱度

    1回答

    如果有IObservable子項的IObservable對象,那麼如何篩選主觀察值以僅包含子屬性至少具有X個數的實例項目。 例如,以下測試用例具有包含2個MyClass的IObservable。第一個包含5個整數的可觀察值和2的第二個。所以我的問題是如何過濾MyClass的IObservable以僅包含包含4個或更多數字的實例? [TestClass] public class TestClas

    1熱度

    1回答

    我使用的是Rx.Net,並且我有Observable可以發出時間序列點(double,timestamp)。每次新點到達時,我都想從最後30秒計算平均值。我想我需要一些不基於計數但是時間戳的重疊窗口/緩衝區。 我發現this主題與SlidingWindow實現,但我無法弄清楚如何適應我的問題。 編輯: 感謝this我才知道,我可以使用掃描操作和緩衝區我的觀點,所以這個basicly解決了這個問題。

    0熱度

    1回答

    我試圖用ReactiveX(更確切地說,Rx.Net)和SQLite.Net構建一個數據訪問層。 工作的一部分是創建一個可觀察的數據庫連接,以便只在需要時纔可以打開它。這是我到目前爲止: var connection = Observable.Create<SQLiteConnection>(observer => { Debug.WriteLine("CheckInStore: Op

    1熱度

    1回答

    以下example var subject = new Subject<int>(); var otherSubject = new Subject<Unit>(); subject .SkipUntil(otherSubject) .Subscribe(Console.WriteLine,() => Console.WriteLine("Completed")); subject.O

    1熱度

    2回答

    我推數據更新/使用的IObservable變化決定管理無限觀察到的一生中,我有一個從數據庫GetLatestElement,每當有人來電話的獲取最新的數據的方法並且數據被更新,消息被分佈在消息傳遞系統上。 public IObservable<IElement> GetElement(Guid id) { return Observable.Create<T>((observer) =

    0熱度

    1回答

    我有一個視圖模型有以下幾點: enum Detection {NotTriggered, Triggered}; public Detection AlertState => _alertState.Value; public DateTimeOffset? LastAlertTime => _lastAlertTime.Value; 我想怎麼辦有另一個屬性:int Acknowledgement

    2熱度

    3回答

    我想等待(阻止)一個線程,直到時間流逝或另一個流輸出了一個值,我想以下可能做到這一點,但因爲第一個流是空的,它拋出一個異常, // class level subject manipulated by another thread... _updates = new Subject<Unit>(); ... // wait for up to 5 seconds before carryin

    1熱度

    1回答

    當多次調用IConnectableObservable.Connect時,合同應該是什麼? 如果返回的IDisposable被丟棄,應該發佈OnCompleted還是應該斷開連接並允許第二次調用Connect? 如果之前所述第一佈置的連接被稱爲第二時間,應該它: 擲 返回相同的IDisposable,可能具有的代碼 返回不同區域意想不到的處置一個新的IDisposable與某種配置引用計數,並導致