IAsyncBatchObserver<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 IAsyncObserver pour permettre la production et la consommation de lots 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 IAsyncBatchObserver<T>

type IAsyncBatchObserver<'T> = interface

Public Interface IAsyncBatchObserver(Of 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é

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(IList<SequentialItem<T>>)	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.