IAsyncObserver<T>.OnNextAsync(T, StreamSequenceToken) メソッド
定義
重要
一部の情報は、リリース前に大きく変更される可能性があるプレリリースされた製品に関するものです。 Microsoft は、ここに記載されている情報について、明示または黙示を問わず、一切保証しません。
次の項目をコンシューマーに渡します。
このメソッドから返されるタスクは、動作の保証を満たすためにコンシューマーによって項目の処理が十分に処理されている場合に完了する必要があります。
コンシューマーがストリームの (プロデューサー エンドポイント) である場合、タスクは、ストリームの実装がアイテムの責任を受け入れ、配信の保証を満たすことが保証されると完了します。 たとえば、永続的なキューに基づくストリームは、アイテムが永続的に保存されたときにタスクを完了します。 配信が最大で 1 回だけベスト エフォートを提供するストリームは、既に完了しているタスクを返します。
プロデューサーがストリームの (コンシューマー エンドポイント) である場合、アイテムの責任を受け入れたときに、コンシューマー コードによってタスクを完了する必要があります。 特に、ストリーム プロバイダーが少なくとも 1 回の配信を保証する場合は、コンシューマーから返されたタスクが完了するまで、アイテムを配信と見なすべきではありません。
public System.Threading.Tasks.Task OnNextAsync (T item, Orleans.Streams.StreamSequenceToken token = default);
public System.Threading.Tasks.Task OnNextAsync (T item, Orleans.Streams.StreamSequenceToken? token = default);
abstract member OnNextAsync : 'T * Orleans.Streams.StreamSequenceToken -> System.Threading.Tasks.Task
Public Function OnNextAsync (item As T, Optional token As StreamSequenceToken = Nothing) As Task
パラメーター
- item
- T
渡される項目。
- token
- StreamSequenceToken
この項目のストリーム シーケンス トークン。
戻り値
アイテムが受け入れられたときに完了するタスク。