system.reactive

    1

    2答えて

    観測可能な状態を維持するために、より良いRxJavaパターンが何であるかについて質問があります。 シンプルに保つために、システム内で特定の状態(単純なブール値のフラグと見なします)を追跡し、それを観測可能な方法で公開する必要があるStateManagerクラスがあるとします。このマネージャーは非常に長いライフサイクルを持っている class StateManager { Observab

    0

    2答えて

    私はいくつかの購読を作成しています。 アクションを実行するために完了したタイミングを検出する必要があります。 private IList<IDisposable> subscriptions = new List<IDisposable>(); private void CreateSubscriptions(IEnumerable<int> integers) { if (thi

    2

    3答えて

    Observableを作成して、さまざまなソース(他のObservables)から情報を収集する必要があります。各ソースはイベント値に影響しますが、値は前の値(状態マシンの種類)。初期化値と、 class Message{ Integer value; String operation; public Message(Integer value, String op

    0

    2答えて

    次の問題があります。新しいイベントを通知するためにOnNextメソッドを使用する件名があります。ただし、OnErrorというメソッド呼び出しでコード内でシミュレートされる例外が発生することがあります。エラーの原因は時間に依存しますので、同じアクションをもう一度やり直すと数回は成功します。ですから、新しいシーケンスを生成する関数を受け入れるcatchメソッドを使用して、アクションを5回繰り返します。

    0

    2答えて

    私はクラス内にIObservable<Item>を持っており、与えられた時刻に最後のアイテムを観測可能にプッシュする読み取り専用プロパティを公開したいと思います。したがって、Itemの単一の値を提供します。 値がプッシュされていない場合は、デフォルトのの値を戻す必要があります。 私は観察可能なものを購読したり、 "バッキングフィールド"を持たなくてもこれを行うことができますか?

    0

    1答えて

    古い.Net 35プロジェクトを4.xにアップグレードする - > Reactive Framework 4.xはどこでダウンロードしますか? MSDNフォーラムが指摘どこ私はここに見えた:https://msdn.microsoft.com/library/hh242985.aspx?f=255&MSPPError=-2147217396 がDnLoadリンクを見つけることができませんでしたか?

    0

    5答えて

    私は観測対象からゆっくりとライブストリーミングされたコードをいくつか持っています。私は、永続化されたオブジェクトからのライブストリームとそのタイムスタンプを別の観測でシミュレートしたいと思います。 私は配列上でObservable.Return.Delayを使って何かを作ってから、単一の観測値にマージすることができました。私はこれが正しいアプローチではないと感じ、スレッドプールがいっぱいになるとタ

    1

    1答えて

    私は2つの観測値AとBを持っています。 私はAがを発したときにのみがちょうどA押し込ま値、およびBで最新の値の組み合わせで、放出することCを生成したいと思います。

    2

    1答えて

    を実装するクラスThingがあります。別のクラスでは、Thingのコレクションがあり、そのクラスは、これらのすべてのオブザーバブルからの更新に統一的に反応する必要があります。それを行う明白な方法はObservable.Merge()であり、それは一般的に動作します。 の場合、コレクションが変更された場合、マージされたサブスクリプションで新しいThingを購読する必要があります(理論的には削除された

    7

    3答えて

    リアクティブプログラミングでは、2つのストリームが互いに依存する状況によく遭遇します。これらのケースを解決するための慣習的な方法は何ですか? 最小限の例:ボタンAとBがあり、どちらも値を表示しています。 Aをクリックすると、Aの値がBで増加する必要があります。Bをクリックすると、Bの値をAに設定する必要があります。 最初の解決方法F#の例がありますが、任意の言語の回答は歓迎します。 let sol