問題タブ [reactive-programming]

私は最近、ゲーム エンジンの設計について読んでいて、最終的にこれに出くわしました: (関数型) リアクティブ プログラミングとは何ですか?

2 番目に高い評価の回答に示されている例を正確にどのように実装するのか疑問に思っていました。C++ では、マウス座標を格納する値へのポインターを渡し、int の代わりにその値を返すだけで十分簡単です。C# では実際にはできないので、最初の問題があります。すべての値を最新の状態に保つために、「更新」関数を呼び出す必要がありますか?

第二に、構文はどのように処理されますか? 値の割り当ては簡単です。しかし、「マウスの位置を取得し、要求するたびにそこから 14 分を取得する」などの作業は、少し複雑です..

最後に、C# の任意のオブジェクトを直接参照したときに値を返すようにする方法を考えていました。例えば

test は 1 を返します。したがって、1 + test = 2 のようなことを行うことができます

しかし、もし私がのインスタンスを持っていたら

intを一緒に追加しようとしたときに、上記のことを行うことはできません。

私が推測するような幅広い質問で申し訳ありません。その回答で説明されているものと同様の機能を示す簡単な例を示すことができれば、私のすべての質問に回答できると思います..

INotifyPropertyChanged オブジェクトのコレクションがあり、さらに処理するためにすべての PropertyChanged イベントを単一の監視可能なシーケンスにストリーミングしたいと考えています。

ここにコードがあります

単一のサブスクライブは、集計されたシーケンスで何らかの理由でここでは機能しません。(Reactive Extensions の Merge 関数を使用して) 誤って集計したようです。ただし、ループ内のサブスクライブは完全に機能します。

多くのイベント ストリームをリアクティブな拡張機能を使用して 1 つに集約する方法を教えてください。

ありがとう

私は持っています

でも私はしたい

そして、基礎となるオブザーバブルのいずれかが変更されるたびに、observableTournのすべてのサブスクライバーを起動させたいですか？C＃でこれが必要

次のTPLタスクがあります

Aggregateメソッドの実装内に、Observable.Subscriptionの末尾が次のようなものがいくつかあります。

質問は、タスクを存続させ、すべてのサブスクリプションをスピンせずにアクティブに保つための最良の方法は何ですか？

IObservable 問題を生成する次の Rx クエリがあります。これは Publish() では機能しないため、サブスクライバーの数が増加するとメモリ負荷も増加します。

そのような Observable を作成するより良い方法はありますか?

RXを使用してWCFからデータをダウンロードしようとしています。ただしObservable.FromAsyncPattern()、組み合わせて使用​​しても応答は返されませんSelecMany

以下のスニペットでこの問題を強調しようとしました。

したがって、RXをSelecMany正しく理解していれば、上記のコードは次のように出力されます。

"私はここにいます"

「ここに行けない:(」

ただし、最初の行のみが印刷され、2番目の行は印刷されません。

編集：このコードはデバッガーが接続されていなくても正常に実行されますが、デバッガーなしで実行すると失敗することを忘れました

WinformでRxを使用することを学んでいます。このコードを使用するときに、progressBar を更新する方法を教えてください。

rx で Observable.Buffer を使用する方法の例を探していましたが、ボイラー プレートの時間バッファリングされたものよりも実質的なものを見つけることができません。

「bufferClosingSelector」を指定するためのオーバーロードがあるようですが、私はそれを気にすることはできません。

私がやろうとしているのは、時間または「累積」によってバッファリングするシーケンスを作成することです。すべてのリクエストに何らかの重みがあり、一度に x 累積された重みを超えて処理したくないリクエスト ストリームを考えてみます。または、十分な量が蓄積されていない場合は、最後の時間枠 (通常のバッファ機能)

私のアプリケーションでは、Webリクエストを行うためにReactive拡張機能を使用しています。私の問題は、2つのリクエストを行っていることです。最初のリクエストでは、サーバーからURLを取得し、そのURLを使用して、画像と説明を取得するための別のリクエストを送信しています。URL以外の最初のリクエストでは、タイトルと日付に関連する情報を取得します。つまり、私が行っているのは、モデルクラスのデータを解析し、そこから他のリクエストを呼び出すことです。ここで応答を受け取ったら、結果を保持できるクラスオブジェクトにそれを追加します。そして、最初のリクエストのcomplete（onnext、error、complete）部分に到達すると、両方の結果がプロパティに表示されます。しかし、問題は、対応する変更、つまり2番目のWebリクエストの結果が私のUIに反映されていないことです。この問題を回避するために誰か助けてください。

私は、次のようなツイートシャープを使用して、観察可能なツイーターフィードを作成しようとしています。

しかし、私はそれを機能させることができません誰かが助けることができますか？