system.reactive

    3熱度

    2回答

    當我寫.Subscribe表達我經常發現ReSharper的選擇了我下面的過載,位於mscorlib程序,版本= 4.0.0.0: namespace System { public interface IObservable<out T> { IDisposable Subscribe(IObserver<T> observer); } } 這似乎

    3熱度

    1回答

    我想知道如何對像Observable.Never這樣的單元測試序列。 我該如何確定沒有任何東西會推到序列中?

    0熱度

    1回答

    在我的WPF UI中,我有一個客戶列表。我也有一個Web API服務來獲取單個客戶的配置文件。無論是服務器端和客戶端使用async/await建成是可以取消的。 當用戶從ComboBox選擇「客戶A」,它會觸發服務器調用來獲取客戶的個人資料。 2秒後(服務器操作方法的設計持續時間),數據返回並顯示。如果在選擇「客戶B」2秒鐘內,我的代碼會取消第一個請求並觸發第二個請求。 這一切工作非常棒,是繁忙/

    5熱度

    1回答

    有誰知道適當的更換這個手工如果反應擴展(.NET/C#)/然後/別的運營商? public static IObservable<TResult> If<TSource, TResult>( this IObservable<TSource> source, Func<TSource, bool> predicate, Func<TSource, IObservable

    0熱度

    1回答

    我想添加一個時間間隔到這個可觀察序列(這是在特定的時間段產生一個整數序列),但它似乎沒有工作。當我刪除時間,那麼它的工作時間。我錯誤地應用了計時器嗎? var timer = Observable.Interval(TimeSpan.FromSeconds(2)).Take(4); var nums = Observable.Range(1,1200).Where(a => a % 2 == 0

    0熱度

    1回答

    GandOfFour觀察者模式中的Rx Subject和Subject如何不同?

    0熱度

    1回答

    所以有可能我最終會遇到以下代碼的幾個問題,也許是因爲我使用了Subject,我不確定它是否可以使用。 這很難讓我解釋,我不知道爲什麼,也許我缺乏術語。 我想要做的是有一個類型,它可以註冊幾個觀察對象,所以我可以傳遞這個類型,並將所有觀察對象組合在一起,並從中展示一個可觀察對象。 所以我的第一個問題我感覺我沒有以正確的方式思考事情,我想知道這是正確的還是存在一種更「反應性」的方式? 我的意思是,我有

    3熱度

    2回答

    這裏是設置:有一個聯邦遠程服務返回一個特定的值是否正確或不正確。我們可以根據需要發送請求,最多可以向遠程服務發送50個請求。由於我們只需要使用正確的值,並且可能的值集合很小(〜700),所以我們可以發送15個左右的批量請求50,並且正確的值將成爲結果集的一部分。因此,我用下面的代碼: Observable .Range(0, requests.Count) .Select(i

    2熱度

    1回答

    我有3個可觀察的事件流 - 按日期順序 - (主要事件,關於銷售的事件和關於客戶的事件) - 每個流包含與各種事件有關的事件類型車輛,每個事件都有車輛ID和各種其他屬性。事件可以出現在一輛車上,然後是另一輛車等。所以基本上我試圖根據VehicleID關聯三個獨立的事件流 - 這聽起來像是應該直截了當的事情。我不熟悉任何形式的複雜可觀察節目,所以這證明相當困難。 我想隨時調用一個函數,在任何流上看到

    3熱度

    2回答

    我有一個可觀察的事情,http處理其他可觀察事件的過程中。 在http獲取除200之外的任何其他響應代碼的情況下,我想記下此錯誤,但繼續進行下一個可觀察事件。 到目前爲止,我有這樣的: this.getConfigurationSettings() .do(config => { console.log('configuration settings.: ', config)