system.reactive

2熱

2答えて

Observable SubscriptionをキャンセルしてObserverが終了するのを待つ

投稿した件名に記載されている内容を達成するために、以下のコードを書くより良い方法はありますか？ Subject<long>を使用すると、次のコードが複雑すぎたり、冗長すぎたりします。一般的なソリューションを作成することは容易ではありません。 var subject = new Subject<long>(); var cts = new CancellationTokenSource(); v

2熱

1答えて

RxUI.NET - 一定期間後にメッセージを非表示にする

Reactive UIを使用しているので、処理が完了した後にメッセージを表示して一定時間（4秒）後にこのメッセージを非表示にしたいと考えています。メッセージが隠れている期間より速く継続している場合は、タイムアウトをリセットして、最後のメッセージが表示/更新されてから4秒後にメッセージが常に非表示になります。最後のメッセージが前のメッセージと同じである場合は、隠蔽も延長する必要があります。現在、私

-1熱

1答えて

メソッドsubscribe（rx.Scheduler）を解決できません

私はこのudemyコースでこの問題を抱えています。すべて正常に動作しますが、私はこの1行でこのエラーが発生し続けます。 Observable<List<String>> userDetailsObservable = Observable.just(userDetails); return userDetailsObservable Error is here--> .s

1熱

1答えて

subcribeOn（観測可能で）io.reactivex.Schedulerはrx.Scheduler

に適用することはできません Iは、約4その他.subscribeOn（Schedulers.io（））が、これは動作しない唯一のものです mSearchBarString = PublishSubject.create(); return mSearchBarString .subscribeOn(Schedulers.io()) 唯一の違いは、この1つはPublish

0熱

3答えて

RX .netでは、Keyでグループ分けされた熱心観測で最新のアイテムをサンプリングできますか？

RX .netでは、Keyでグループ分けされた最新のアイテムを最新のものでサンプリングすることは可能ですか？例えば、私は価格である価格、のIObservableを持っている場合： Price - Key - Bid - Offer はのはIObservableが外部価格フィードにリンクされていると仮定しましょう。 RXを使用して1秒ごとにサンプリングされたキーでグループ化された最新の価

1熱

1答えて

RxNETで非同期HTTPリクエストを作成するにはどうすればよいですか？

現在、私はObservable.Create（）内でawaitを使用しています。 ExecuteRequestAsyncはHttpClient.GetAsync Method (String) public IObservable<IList<ExampleResponseModel>> ListExamplesRx() { return Observable.Create<

0熱

1答えて

2つの配列が

を完了するために、私は非同期的に、彼らは私のBusManagerシーケンス（OrderShouldBeCreated、OrderCreatedを）進めるイベントを発行 BusManager.OrderShouldBeCreated.Subscribe(orderShouldBeCreated =>BusManager.PublishAsync(new OrderCreated()); BusMa

4熱

1答えて

リアクティブプログラミングを使用してFileStreamを開くために書き込む

私は小さなロガーを作成しています。ログファイルを一度開き、ログメッセージが到着するのを待って書き込み続け、プログラムの終了時にすべてを破棄します。私は、彼らが到着した反動メッセージを書き込むと開いたFileStreamを保つことができるかどうかはわかりませんよ。私はバッファとして動作するConcurrentQueueと、キューを消費したusingステートメント内のループを持つ以前のソリューショ