IAsyncBatchObserver<T>.OnNextAsync Metodo

Definizione

Spazio dei nomi:

Orleans.Streams

Assembly:

Orleans.Streaming.dll

Pacchetto:

Microsoft.Orleans.Streaming v8.2.0

Passa il batch successivo di elementi al consumer.

L'attività restituita da questo metodo deve essere completata quando l'elaborazione degli elementi è stata sufficientemente elaborata dal consumer per soddisfare eventuali garanzie comportamentali.

Quando il consumer è l'endpoint del produttore di un flusso, l'attività viene completata quando l'implementazione del flusso ha accettato la responsabilità per gli elementi e viene assicurata di soddisfare le garanzie di recapito. Ad esempio, un flusso basato su una coda durevole completa l'attività quando gli elementi sono stati salvati in modo permanente. Un flusso che fornisce il massimo sforzo una volta che il recapito restituirà un'attività già completata.

Quando il produttore è l'endpoint consumer di un flusso, l'attività deve essere completata dal codice consumer quando ha accettato la responsabilità degli elementi. In particolare, se il provider di flusso garantisce il recapito almeno una volta, gli elementi non devono essere considerati recapitati fino al completamento dell'attività restituita dal consumer.

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

Parametri

items

IList<SequentialItem<T>>

Elemento da passare.

Restituisce

Task

Attività completata quando l'elemento è stato accettato.