IAsyncBatchProducer<T>.OnNextBatchAsync Método

Definição

Namespace:

Orleans.Streams

Assembly:

Orleans.Streaming.dll

Pacote:

Microsoft.Orleans.Streaming v8.2.0

Passa o próximo lote de itens para o consumidor.

A Tarefa retornada desse método deve ser concluída quando todos os itens no lote tiverem sido processados suficientemente pelo consumidor para atender a quaisquer garantias comportamentais.

Ou seja, a semântica da Tarefa retornada é a mesma que para OnNextAsync(T, StreamSequenceToken), estendida para todos os itens no 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>

Os itens a serem passados.

token

StreamSequenceToken

O token de sequência de fluxo deste item.

Retornos

Task

Uma Tarefa que é concluída quando o lote é aceito.