IAsyncBatchObserver<T>.OnNextAsync 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 o processamento dos itens tiver sido processado suficientemente pelo consumidor para atender a quaisquer garantias comportamentais.

Quando o consumidor é o (ponto de extremidade do produtor de) um fluxo, a Tarefa é concluída quando a implementação do fluxo aceita a responsabilidade pelos itens e tem a garantia de cumprir suas garantias de entrega. Por exemplo, um fluxo baseado em uma fila durável concluiria a Tarefa quando os itens tiverem sido salvos de maneira durável. Um fluxo que fornece melhor esforço no máximo uma vez que a entrega retornaria uma Tarefa que já está concluída.

Quando o produtor é o (ponto de extremidade do consumidor de) um fluxo, a Tarefa deve ser concluída pelo código do consumidor quando tiver aceitado a responsabilidade pelos itens. Em particular, se o provedor de fluxo garantir pelo menos uma entrega, os itens não deverão ser considerados entregues até que a Tarefa retornada pelo consumidor seja concluída.

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

Parâmetros

items

IList<SequentialItem<T>>

O item a ser passado.

Retornos

Task

Uma Tarefa que é concluída quando o item foi aceito.