問題タブ [rx.net]

特定のロジックでアイテムを通過する方法を探しています。最も明白な答えは、おそらくほとんどの場合で動作する .Select を使用することですが、私には特別なケースがあり、質問は実際には、アイテムがすべてのサブスクライバーによって消費された後に特定のメソッドを呼び出す方法として言い換えることができますか?

このような拡張機能を考えてPassThrough(this IObservable<TSource> obj, Action<TSource, IObserver<TResult>> selector)いましたが、次のように使用します

これの最も重要な部分は、オブジェクトが OnNext に渡された後、つまりサブスクライバーによって消費された後、結果オブジェクトに対して .Dispose を呼び出すことです。そのような拡張方法は見つかりませんでした。既存のRx.NET APIでそれを達成する方法、またはこれを行う拡張機能を作成する方法を誰かが例を挙げてもらえますか?

クエリを実行して一連の結果を返す非同期メソッドがあるとします。

そして、結果セットを再度フェッチする必要があるたびに起動するオブザーバブルがあります。

私が欲しいのは：

(1) クエリを実行して最初の結果セットを生成し、(2) 起動するたびNeedToRefetchにクエリを再度実行して別の結果セットを生成します。

このオブザーバブルを構成する最良の方法は何ですか?

その最初の結果セットが必要ない場合は、次のようにすることができます。

したがって、クエリが少なくとも 1 回実行されるようにするには、次のようにします。

しかし、その後、コールド オブザーバブルとホット オブザーバブルについて読み始め、代わりに次のようなことをすべきかどうか疑問に思いました。

そして、これは私が使用することになっているケースであるかどうか疑問に思いました Observable.Create.

そして、私は疑問に思うのをやめて、この質問を書きました。