Compartir a través de


IAsyncBatchProducer<T>.OnNextBatchAsync Método

Definición

Pasa el siguiente lote de elementos al consumidor.

La tarea devuelta desde este método debe completarse cuando el consumidor haya procesado suficientemente todos los elementos del lote para cumplir las garantías de comportamiento.

Es decir, la semántica de la tarea devuelta es la misma que para OnNextAsync(T, StreamSequenceToken), extendida para todos los elementos del lote.

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

Parámetros

batch
IEnumerable<T>

Elementos que se van a pasar.

token
StreamSequenceToken

Token de secuencia de secuencia de este elemento.

Devoluciones

Tarea que se completa cuando se ha aceptado el lote.

Se aplica a