IAsyncObserver<T>.OnNextAsync(T, StreamSequenceToken) Méthode

Définition

Espace de noms:

Orleans.Streams

Assembly:

Orleans.Streaming.dll

Paquet:

Microsoft.Orleans.Streaming v8.2.0

Transmet l’élément suivant au consommateur.

La tâche retournée par cette méthode doit être terminée lorsque le traitement de l’élément a été suffisamment traité par le consommateur pour répondre à toutes 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é de l’article 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 l’élément a été enregistré durablement. Un flux qui fournit le meilleur effort au plus 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é de l’élément. En particulier, si le fournisseur de flux garantit au moins une livraison, l’article ne doit pas être considéré comme livré tant que la tâche retournée par le consommateur n’est pas terminée.

public System.Threading.Tasks.Task OnNextAsync (T item, Orleans.Streams.StreamSequenceToken? token = default);

abstract member OnNextAsync : 'T * Orleans.Streams.StreamSequenceToken -> System.Threading.Tasks.Task

Public Function OnNextAsync (item As T, Optional token As StreamSequenceToken = Nothing) As Task

Paramètres

item

T

Élément à passer.

token

StreamSequenceToken

Jeton de séquence de flux de cet élément.

Retours

Task

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