IObservable <T>からタスクへ

debugcn 投稿 Dev

サンティアゴセロンウリベ

だからケースはこれです。どこかでコレクションを埋めているとします。要素が追加されるたびに、IObservableはサブスクライバーに対してOnNextを呼び出します。

さて、コレクションがいっぱいになるポイントがあります。（私は何かを読んでいて、読み終えました..何でも）。その時点で、OnComplete（）がサブスクライバーで呼び出されます。

ただし、ユーザーはこの方法を順守しません。彼はむしろ彼が待つ非同期メソッドを呼び出すでしょう...彼は彼が読んだものについてはあまり気にしません、彼はただ彼が読み終えたことを気にします。

したがって、基本的には、IObservableから、IObservableがOnComplete（）をサブスクライバーに呼び出したときに戻るタスクが必要です。特に、ユーザーがオブザーバーを使用しないようにしたいのですが、待機呼び出しの後に発生することはすべて、コレクションがいっぱいになった後に発生することを知って満足しています。

たぶんToTask（）メソッドがトリックをしますか？ドキュメントでは本当にわかりません。

ネッド・ストヤノフ

Rx 2.0以降を使用している場合await IObservableは、オブザーバブルの最後のアイテムを返すことができます。つまり、オブザーバブルが完了した後です。

var lastItem = await myObservable;

これが可能なのは、Rx 2.0でGetAwaiter拡張メソッドIObservableが追加され、awaitオブザーバブルが可能になったためです。待機する要素を指定できる便利な拡張メソッドもいくつかあります。

ここにそれについての素晴らしいブログがあります。

この記事はインターネットから収集されたものであり、転載の際にはソースを示してください。

侵害の場合は、連絡してください[email protected]

編集2021-05-28

コメントを追加

サインイン

分類Dev

Related 関連記事

記事

IObservable <T>からタスクへ

IObservable <T>からタスクへ

Turn an IObservable<IEnumerable<T>> into an IEnumerable<IObservable<T>>

linqクエリを使用したIObservable <T>

IObservable <IEnumerable <T >>は本当にIObservable <T>である必要がありますか？

IObservable <IEnumerable <T >>을 IEnumerable <IObservable <T >>로 변환

Spit IObservable<T> exceptions in a separate IObservable<Exception> and continue normally

IObservable <T>をIObservable <IObservable <T >>に分割します

Converting a IEnumerable<T> to IObservable<T>, with maximum parallelism

IObservable <T>からデータグリッドを自動的に更新する方法

IObservable <T>をIAsyncEnumerable <T>に変換することは可能ですか？

IObservable <T> .ToTask拡張メソッドはどこにありますか？

IObservable<Task<T>> を順序保持で IObservable<T> にアンラップする

IObservableを上から排出します

IObservable.Subscribe（IObserver <T>オブザーバー）オーバーロードとは何ですか？

IEnumerable <T>やIObservable <T>のようなプッシュベースの構造とプルベースの構造の違いは何ですか

IObservable <int>を使用してIObservable <T>をさまざまな長さのIObservable <T []>にセグメント化する方法

Func <T>に基づいてIObservable <T>をチャンクにウィンドウ/バッファリングする方法

IObservable <T>例外を別のIObservable <Exception>に吐き出し、通常どおり続行します

How can I make an IObservable from a queue, so that the sequence doesn't end when the queue is empty?

SignalRから共有IObservableを消費する

IObservableから最新のメッセージを取得する

最大の並列処理でIEnumerable <T>をIObservable <T>に変換する

例外処理を除いて、IEnumerable <Task <T >>をIObservable <T>に変換します

IObservableの無効なキャスト、ランタイム例外

カスタムEventHandlerをIObservableに変換する

IObservableからIEnumerableに変換するリアクティブ拡張

IObservableからIEnumerableに変換するリアクティブ拡張

タスクを順番に実行し、結果をIObservableに入れる方法

1つのボタンで複数のIObservableを調整する

IObservable <byte []>変換