IAsyncObserver<T> Interface

Définition

Espace de noms:

Orleans.Streams

Assembly:

Orleans.Streaming.dll

Paquet:

Microsoft.Orleans.Streaming v8.2.0

Cette interface généralise l’interface .NET IObserver standard pour permettre la production asynchrone d’éléments.

Notez que cette interface est implémentée par les consommateurs d’éléments et appelée (utilisée) par les producteurs d’éléments. Cela signifie que le point de terminaison consommateur d’un flux implémente cette interface.

public interface IAsyncObserver<in T>

type IAsyncObserver<'T> = interface

Public Interface IAsyncObserver(Of In T)

Paramètres de type

T

Type d’objet consommé par l’observateur.

Ce paramètre de type est contravariant. Cela signifie que vous pouvez utiliser le type spécifié ou tout type moins dérivé. Pour plus d’informations sur la covariance et la contravariance, consultez Covariance et contravariance dans les génériques.

Dérivé

Orleans.Streams.IAsyncBatchProducer<T>

Orleans.Streams.IAsyncStream<T>

Méthodes

OnCompletedAsync()	Avertit le consommateur que le flux a été terminé. La tâche retournée par cette méthode doit être terminée lorsque le consommateur a terminé de traiter la fermeture du flux.
OnErrorAsync(Exception)	Avertit le consommateur que le flux a rencontré une erreur. La tâche retournée par cette méthode doit être terminée lorsque le consommateur a terminé de traiter la fermeture du flux.
OnNextAsync(T, StreamSequenceToken)	Passe 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 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é de l’élément 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 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é de l’élément. En particulier, si le fournisseur de flux garantit au moins une remise, l’élément ne doit pas être considéré comme remis tant que la tâche retournée par le consommateur n’est pas terminée.