購読 API

Observable を購読し、通知を受け取ったり、シーケンスの完了を待機したりする API をまとめています。

← トップに戻る

API 一覧

API	概要
Subscribe	Observable を購読し、通知をコールバックで受け取る
SubscribeAwait	非同期の OnNext ハンドラで Observable を購読する
ForEachAsync	各要素を処理し、シーケンスの完了を Task として待機する

使い分け

• 通知を受け取り続け、不要になったら IDisposable で購読解除したい → Subscribe
• OnNext の処理に async / await を使いたい → SubscribeAwait
• シーケンス全体の完了や失敗を await し、try-catch で扱いたい → ForEachAsync

Subscribe と SubscribeAwait は購読を開始して IDisposable を返します。ForEachAsync はシーケンスを最後まで消費し、完了を Task として返す終端操作です。