system.reactive

3熱

2答えて

コレクションから取得したIObservablesのサブスクリプションが機能しない理由とその対処方法

私の目標は、ソースオブザーバブルから一連のオブザーバブルを作成して、個別にサブスクライブできるようにすることです。 これを手動で行うと（つまり、各サブソースを手動で作成すると）、元のソースに追加された値がサブソースに適切に伝播します。 しかし、私は、ループ内でそれらを作成List<IObservable<T>>にそれらを追加するとき、そのリストから取られた要素へのサブスクリプションが動作していない

system.reactive 2017-01-14

---

1熱

3答えて

コールバックをRx.Observableに変換するには？

外部ライブラリがイベントの代わりにコールバックを登録するだけの場合は、Observableを作成する最も良い方法は何ですか？ イベントの場合はObservable.FromEventPatternを使用できますが、このケースでは私が持っている唯一のアイデアは、Subjectを使用し、各コールバックでイベントをキューに入れることです。 これを行うにはもっと良い方法はありますか？

system.reactive 2017-01-15

---

2熱

1答えて

観測値から最後に放出された値をキャッシュする

多くの場合、観測値から最近放出された値にアクセスする必要があります。私がこれをやったやり方は、観測値とキャッシング値が現れたときにそれを購読することです。例えば以下を参照してください。しかしObservable.MostRecent、Observable.Latest、Replay（1）など、私が探しているものを達成するかもしれないような方法がたくさんあるのがわかりますが、使い方を理解できません。

system.reactive 2017-01-16

---

1熱

1答えて

リアクティブエクステンション：ショート状態の変更を無視する方法

私のXamarin Appからのインターネット接続の状態変化を観察したいと思います。私はObservableに変換するConnectivityChangedイベントを提供するConnectivity Pluginを使用します。これは正常に動作します。 問題は、電話が切り替わるときなどです。 3Gから4Gまで、私は無視したい短い切断があります。 これまでのところ、ThrottleとDistinctを

system.reactive 2017-01-18

---

1熱

1答えて

CでRXを使った自動保存

自動保存機能を実装したいと思います。私は2つの観測があります IObservable<Unit> changes：アイテムは、ユーザーがテキスト IObservable<Unit> savesを編集するたびに発する：保存イベントに保存ボタンが を押すたびに発する今私は、結合したいです第3ストリームへのそれらwriteBack。このストリームには、現在のテキストをデータベースに書き込むサブスクライバ

c# system.reactive autosave rx.net 2017-01-22

---

0熱

2答えて

IObservableを使用したダイアログのやりとり要求

私はMVVMアプリケーションを構築するためにリアクティブプログラミングを使用しています。私のビューモデルがどのように質問を出し、ユーザーに回答を促すダイアログが出るのを待っていますか？ たとえば、ユーザーが名前の変更ボタンをクリックすると、ユーザーがテキストを変更できるダイアログが表示されます。私のアプローチは、ビューモデルがIObservable<string>プロパティを公開することです。ビュ

system.reactive 2017-01-23

---

1熱

2答えて

リアクティブエクステンション：他のストリームが完了するまでのバッファ

リクエストを行い、そのリクエストに対するレスポンスをレスポンスストリームで待つ。待っている間、Updatesストリームの更新があるかもしれません。 応答ストリームが完了したら、これらの更新が必要です。このように： Response (cold) | x y z | Updates (hot) | 1 2 3 4 | Result | x y z 123 4 | 私はそれを正し

.net system.reactive 2017-01-23

---

0熱

1答えて

バッファリングされたobservableは、各間隔でonNextの値を提供するのではなく、なぜ完了していますか？

私はprocessedMessagesと呼ばれるObservableを持っています。私はこれらのメッセージをバッファリングし、10個のメッセージごと、または30秒ごとに外部キューから削除する必要があります。このコードは、私のサービスのコンストラクタによって呼び出され this.processedMessages.Where(m => m != null && some criteria here)

.net system.reactive 2017-01-27

---

4熱

2答えて

Reactive Extensionsを使用して状態をポーリングするにはどうすればよいですか？

反応（Database polling with Reactive Extensions）を使用して、データベース・ポーリングに良い質問がまだあり 私は同様の質問を持っていますが、ひねりを加えた：私は、次の要求に前の結果から値を供給する必要があります。基本的に、私はこれをポーリングしたいと思います： interface ResultSet<T> { int? CurrentAsOfHa

c# system.reactive rx.net 2017-01-27

---