system.reactive

    1熱度

    1回答

    F＃反應從COM訂閱非標準事件

    我有一個原生COM庫（我可以修改），並且我有一個F＃應用程序嘗試從項目中引用的Interop庫中使用Rx消耗事件。 let events = obj :?> _IInteropEvents_Event let disposable = Observable.take 1 events.ComEventArrived |> Observable.subscribe (fun s
    events f# com system.reactive com-interop 2017-04-20

    1熱度

    1回答

    使用DataFlow和RX的連續數據流停止處理

    我建立了一個系統，可以無限期地從隊列中讀取消息，然後使用Rx和TPL DataFlow將它們關閉。 出於某種原因，在幾百條消息之後，ActionBlock停止運行掛起，我找不到原因。 this.GetMessages()繼續着火，但this.ProcessMessages不再。 var source = Observable .Timer(TimeSpan.FromMillisecond
    .net async-await system.reactive tpl-dataflow 2017-04-20

    0熱度

    1回答

    反應擴展：轉換同步訂閱異步

    我必須同步訂閱類似地實現對這段代碼可觀察到的數據序列： integers.Where(id => (id & 1) == 0).Subscribe(id => evenHandler.LRP(id, RandomDelay())); integers.Where(id => (id & 1) == 1).Subscribe(id => oddHandler.LRP(id, RandomDelay
    c# asynchronous system.reactive 2017-04-21

    2熱度

    1回答

    C＃如何重啓的RX訂閱

    假設我們有這個觀察到的序列（RX）和匹配訂閱： var behaviorSubject = new BehaviorSubject<int>(3); var sequence = behaviorSubject.Select(x => this.webservice.Call(x)).Switch(); var subscription = this.sequence.Subscribe(th
    c# wpf system.reactive 2017-04-22

    1熱度

    1回答

    如何依次發出最後一個匹配元素？

    我有一個排序順序的事件流。每個事件都是具有關鍵屬性（即其ID）的組的一部分。這些事件對於非ID屬性具有不同的值。我希望在身份證更改之前忽略除最終事件之外的所有事宜。例如 {ID:1, Prop: "V1"}, {ID:1, Prop:"V2"}, {ID:1, Prop:"V3"}, {ID:2, Prop:"V1"}, {ID:2, Prop:"V2"}, {ID:2, Prop:"V3"},
    system.reactive reactive-programming 2017-04-22

    0熱度

    2回答

    從IObservable轉換爲IEnumerable的無功擴展

    給定一個Observable，一旦調用了Subscribe，就會開始推送事件。如何將序列轉換爲IEnumerable。 在2010年，Jon Skeet寫到了他對RX的第一印象，並寫道這與我所需要的相當。 public static List<T> ToList<T>(this IObservable<T> source) { List<T> ret = new List<T>();
    c# .net system.reactive 2017-04-23

    3熱度

    1回答

    F＃反應等待Observable完成

    我發現了很多關於此的SO問題，但找不到F＃解決方案。我需要阻止等待事件向我開火以檢查它返回的數據。我使用的Rx接收事件3次： let disposable = Observable.take 3 ackNack |> Observable.subscribe ( fun (sender, data) -> Console.WriteLine("{0}",
    f# system.reactive xunit 2017-04-24

    2熱度

    1回答

    是否有一個C＃System.RxJava的doOnSubscribe的反應版本？

    在RxJava中，我傾向於使用Observable.doOnSubscribe來記錄何時訂閱observable（知道何時創建\ fetch數據的工作正在發生），並發現在調用某些繁重工作時發現錯誤時很有用。 Do()運營商似乎提供doOnNext(), doOnError(), doOnCompleted() RxJava功能，但uniess我錯過了它，它似乎沒有提供類似於doOnSubscrib
    system.reactive 2017-05-02

    0熱度

    3回答

    轉換對象匿名類型

    如何遍歷如果我詢問消息的類型和打印傳遞在如下(first, second, third) => new { One = first, Two = second, Three = third } 對象的anonymous type的IEnumerable的，它說：<>f__AnonymousType0 3[MtApi.MtQuote,MtApi.MtQuote,MtApi.MtQuote] //**
    c# linq system.reactive anonymous-types 2017-05-05

    0熱度

    1回答

    如何正確重組分組觀察值？

    我正在嘗試創建一個分析股票價格的工具。 我得到了不同股票的價格數據流，我希望有一個可觀察的事件，當它收到一個新的，獨特的和完整的價格集合時發出事件。 我的計劃：將流分組爲不同股票的不同子流，並重新組合它們的最新值。 比方說，我有一個事件流是這樣的： from rx import Observable stock_events = [ {'stock': 'A', 'price': 1
    python-3.x system.reactive reactive-programming reactivex rx-py 2017-05-06
最新問題