Partager via


IAsyncBatchObserver<T>.OnNextAsync Méthode

Définition

Transmet le lot d’éléments suivant au consommateur.

La tâche retournée par cette méthode doit être effectuée lorsque le traitement des éléments a été suffisamment traité par le consommateur pour respecter les garanties comportementales.

Lorsque le consommateur est le (point de terminaison du producteur) d’un flux, la tâche est terminée lorsque l’implémentation du flux a accepté la responsabilité des éléments et est assuré de respecter ses garanties de livraison. Par exemple, un flux basé sur une file d’attente durable terminerait la tâche lorsque les éléments ont été enregistrés durablement. Un flux qui fournit le meilleur effort au maximum une fois la livraison retournerait une tâche déjà terminée.

Lorsque le producteur est le (point de terminaison du consommateur) d’un flux, la tâche doit être terminée par le code du consommateur lorsqu’il a accepté la responsabilité des éléments. En particulier, si le fournisseur de flux garantit au moins une remise, les éléments ne doivent pas être considérés comme remis tant que la tâche retournée par le consommateur n’est pas terminée.

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

Paramètres

items
IList<SequentialItem<T>>

Élément à passer.

Retours

Tâche terminée lorsque l’élément a été accepté.

S’applique à