問題タブ [rx.net]

動作IObservable<T>を使用する方法がありThrottleます (アイテムが追加されたときにタイマーをリセットしますが、その時間内に追加されたすべてのアイテムのコレクションを返すようにしますか?

Buffer同様の機能を提供し、タイムスIList<T>パンまたはカウントごとにデータをチャンクアップします。しかし、アイテムが追加されるたびにリセットする時間が必要です。

ここで同様の質問を見てきました。リアクティブ拡張機能はローリング バッファをサポートしていますか? 、しかし答えは理想的ではないようで、少し古いので、Rx-Mainのリリースバージョンがすぐにこの機能をサポートするようになったかどうか疑問に思いました。

SlidingWindow移動平均などを簡単に監視したいので、リアクティブエクステンションの演算子を作成しました。簡単な例として、マウスイベントを聞くためにサブスクライブしたいのですが、イベントがあるたびに、最後の3つを受け取りたいです（ 3つおきのイベントが最後の3つを受け取るのを待っています）。そのため、私が見つけたウィンドウのオーバーロードでは、箱から出して必要なものが得られないようです。

これが私が思いついたものです。リスト操作が頻繁に行われることを考えると、これが最もパフォーマンスの高いソリューションではない可能性があることを恐れています。

これは次のように呼び出すことができます。

しかし、驚いたことに、期待される結果を受け取る代わりに

結果を受け取ります

どんな洞察も大歓迎です！

Rx サブスクリプション内で非同期関数をコールバックしたいと考えています。

例：

例外を適切にキャッチするには、何をする必要がありますか?

UML ダイアグラムを使用して、Rx コードをよりよく理解したい。次に、VS2013 コミュニティを使用して生成します。しかし、それは失敗しました。

「コレクションが変更されました。列挙操作が実行されない可能性があります」という文のダイアログが表示されます。理由は何ですか？そして、それを修正する方法は？

このビデオから、Jonathan Worthington による Twitter の例を再構築しようとしました: https://www.youtube.com/watch?v=_VdIQTtRkb8

それはうまくいき始めます。しかし、しばらくするとストリームが停止します。入力された 3 番目の検索トピックで、アプリはツイートを受信しなくなりました。そして、私には理由がわかりません。時間に依存しないようです。検索トピックを変更せずに実行すると、続行されるためです。誰でも助けることができますか？

メインウィンドウのコードは次のとおりです。

これは XAML コードです。

IObservable の作成方法は次のとおりです。

最後に、感情分析:

のバッファをクリアするにはどうすればよいReplaySubjectですか?

定期的にバッファをクリアする必要があります (私の場合は 1 日の終わりのイベントとして)ReplaySubject継続的に成長し、最終的にすべてのメモリを消費するのを防ぎます。

ReplaySubject理想的には、クライアントのサブスクリプションがまだ良好であるため、同じ状態を維持したいと考えています。

私のシステムには、接続ステータス、CPU 負荷、ログに記録されたユーザーなど、多くのステータス オブジェクトがあります。このようなイベントはすべて、単一の監視可能なストリームにマージされます。

システムの実際のステータスを表示し、そのすべてのカウンターを表示する管理ユーティリティを作成したいと考えています。

すべてのカウンターの最後に変更された値のリストを持つオブザーバブルを作成するにはどうすればよいですか?

これが私が欲しい大理石の図です：

望ましい出力:

これまでのところ、この実装にできます:

そして、ここに使用例があります：

そして Dump 関数 ( Lee Campbell の素晴らしい本から):

問題は、この機能を実装するためのより良い方法はありますか? おそらく、オブザーバブル内で Dictionary を使用していませんか?

ありがとうございました。