IAsyncBatchObserver<T>.OnNextAsync メソッド

定義

名前空間:

Orleans.Streams

アセンブリ:

Orleans.Streaming.dll

パッケージ:

Microsoft.Orleans.Streaming v8.1.0

項目の次のバッチをコンシューマーに渡します。

このメソッドから返されるタスクは、動作の保証を満たすためにコンシューマーによって項目の処理が十分に処理されている場合に完了する必要があります。

コンシューマーがストリームの (プロデューサー エンドポイント) である場合、タスクは、ストリームの実装がアイテムの責任を受け入れ、配信の保証を満たすことが保証されると完了します。 たとえば、永続的なキューに基づくストリームは、アイテムが永続的に保存されたときにタスクを完了します。 配信が最大で 1 回だけベスト エフォートを提供するストリームは、既に完了しているタスクを返します。

プロデューサーがストリームの (コンシューマー エンドポイント) である場合、アイテムの責任を受け入れたときに、コンシューマー コードによってタスクを完了する必要があります。 特に、ストリーム プロバイダーが少なくとも 1 回の配信を保証する場合は、コンシューマーから返されたタスクが完了するまで、アイテムを配信と見なすべきではありません。

public System.Threading.Tasks.Task OnNextAsync (System.Collections.Generic.IList<Orleans.Streams.SequentialItem<T>> items);

abstract member OnNextAsync : System.Collections.Generic.IList<Orleans.Streams.SequentialItem<'T>> -> System.Threading.Tasks.Task

Public Function OnNextAsync (items As IList(Of SequentialItem(Of T))) As Task

パラメーター

items

IList<SequentialItem<T>>

渡される項目。

戻り値

Task

アイテムが受け入れられたときに完了するタスク。