次の方法で共有


IAsyncBatchProducer<T>.OnNextBatchAsync メソッド

定義

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

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

つまり、返される Task のセマンティクスは、 と同じ OnNextAsync(T, StreamSequenceToken)であり、バッチ内のすべての項目に対して拡張されます。

public System.Threading.Tasks.Task OnNextBatchAsync (System.Collections.Generic.IEnumerable<T> batch, Orleans.Streams.StreamSequenceToken token = default);
abstract member OnNextBatchAsync : seq<'T> * Orleans.Streams.StreamSequenceToken -> System.Threading.Tasks.Task
Public Function OnNextBatchAsync (batch As IEnumerable(Of T), Optional token As StreamSequenceToken = Nothing) As Task

パラメーター

batch
IEnumerable<T>

渡される項目。

token
StreamSequenceToken

この項目のストリーム シーケンス トークン。

戻り値

バッチが受け入れられたときに完了するタスク。

適用対象