system.reactive

    2熱度

    1回答

    我正在使用反應式UI,我想在完成一個過程後顯示一條消息,並在一段時間(4秒)後隱藏此消息。如果消息比隱藏時間快,則應重置超時,以便在最後一條消息顯示/更新後的4秒後始終隱藏消息。如果最後一條消息與之前的消息相同,則隱藏時間也應該延長。 目前我有這個代碼,這是我想要的,但它看起來太麻煩了。我只是在試用RxUI,所以大部分時間我都不知道自己在做什麼。有沒有更好的方法來實現這個目標? public cl

    -1熱度

    1回答

    所以我遇到了這個我一直在關注的udemy課程的問題。一切工作正常,但我不斷收到此錯誤在這一行。 Observable<List<String>> userDetailsObservable = Observable.just(userDetails); return userDetailsObservable Error is here--> .subscribe(Sch

    1熱度

    1回答

    我對其他4個.subscribeOn(Schedulers.io()),但是這僅僅是不工作的一個 mSearchBarString = PublishSubject.create(); return mSearchBarString .subscribeOn(Schedulers.io()) 唯一不同的是,別人用 Observable<JSONObject> jsonO

    4熱度

    3回答

    對Xamarin.Forms使用RxUI,你將如何創建一個只能自動執行一次的命令(當頁面初始出現時),但是te用戶可以稍後請求它的執行(比如從pull到refresh類型事件)? 我已經使用FromEventPattern將我的命令掛鉤到Appearing事件,但是當我導航回頁面時,它會再次執行,這是一種不希望的行爲。 這是我的場景:當用戶打開包含它的頁面時,我需要一個列表自動填充。然後,用戶可以

    1熱度

    1回答

    方案 我收到通知型動物IDS每100毫秒(源1),我需要做的把每一個ID與高速緩存具體收到的日期,如果id來了兩次,我只更新日期。之後,我需要搜索調用服務的ID的信息,當我在我的應用程序上收到該信息時,我需要按接收日期排序,每5秒更新一次屏幕。如果有任何ID沒有在10秒由源1的範圍內刷新,它需要改變國家在不同的類別或狀態 問題 我試圖使用無功擴展顯示它要解決這個問題,但我不知道這是否是正確的技術,

    1熱度

    1回答

    目前我正在使用Observable.Create()內的await。 ExecuteRequestAsync是一個包裝類叫HttpClient.GetAsync Method (String) public IObservable<IList<ExampleResponseModel>> ListExamplesRx() { return Observable.Create<

    2熱度

    2回答

    我有一個可觀察的鏈,最初的觀察者來自網絡,並且每當消息準備被讀取時就會被觸發。接下來的處理程序然後讀取消息並將其反序列化。現在我有一個observable分支,一個是消息處理程序,另一個是記錄消息。 的問題是,因爲我觀察到的使用我實際上將嘗試讀取消息的兩倍。 據我所知,使用事件,而不是可觀察就能解決問題,但我會再有一個垃圾收集問題,可能導致無法收集套接字。 一種解決方案我想的是插入某種分離器的其中

    1熱度

    1回答

    我有一個遠程程序,它通過套接字連接每10毫秒發送一次更新的度量。在我的客戶端程序中,我將這個套接字包裝在一個可產生這些測量結果的觀察值中對於我的用例來說,測量到達10毫秒間隔很重要。當然,這種情況不會發生,因爲網絡延遲會使信息早或晚地到達每條信息。 所以基本上我在遠程PC上有一個程序在套接字連接上發送它。 --爲10毫秒 o--o--o--o--o--o--o--o--o--o--... 這成

    9熱度

    1回答

    我有一個簡單的同步方法,看起來像這樣: public IEnumerable<Foo> MyMethod(Source src) { // returns a List of Oof objects from a web service var oofs = src.LoadOofsAsync().Result; foreach(var oof in oofs)

    0熱度

    1回答

    我有一個像 BusManager.OrderShouldBeCreated.Subscribe(orderShouldBeCreated =>BusManager.PublishAsync(new OrderCreated()); BusManager.PublishAsync(new OrderShouldBeCreated()); 守則,異步發佈,然後他們提出我的BusManager序列