Partager via


IAsyncStream<T> Interface

Définition

Cette interface représente un objet qui sert de rendez-vous distribué entre les producteurs et les consommateurs. Il est similaire à un framework Subject réactif et implémente ni IObservable interfacesIObserver.

public interface IAsyncStream<T> : IComparable<Orleans.Streams.IAsyncStream<T>>, IEquatable<Orleans.Streams.IAsyncStream<T>>, Orleans.Streams.IAsyncBatchObserver<T>, Orleans.Streams.IAsyncObservable<T>, Orleans.Streams.IAsyncObserver<T>, Orleans.Streams.IStreamIdentity
public interface IAsyncStream<T> : IComparable<Orleans.Streams.IAsyncStream<T>>, IEquatable<Orleans.Streams.IAsyncStream<T>>, Orleans.Streams.IAsyncBatchObservable<T>, Orleans.Streams.IAsyncBatchProducer<T>, Orleans.Streams.IAsyncObservable<T>, Orleans.Streams.IAsyncObserver<T>, Orleans.Streams.IStreamIdentity
public interface IAsyncStream<T> : IComparable<Orleans.Streams.IAsyncStream<T>>, IEquatable<Orleans.Streams.IAsyncStream<T>>, Orleans.Streams.IAsyncBatchObservable<T>, Orleans.Streams.IAsyncBatchProducer<T>, Orleans.Streams.IAsyncObservable<T>, Orleans.Streams.IAsyncObserver<T>, Orleans.Streams.IAsyncStream
type IAsyncStream<'T> = interface
    interface IStreamIdentity
    interface IEquatable<IAsyncStream<'T>>
    interface IComparable<IAsyncStream<'T>>
    interface IAsyncObservable<'T>
    interface IAsyncBatchObserver<'T>
    interface IAsyncObserver<'T>
type IAsyncStream<'T> = interface
    interface IStreamIdentity
    interface IEquatable<IAsyncStream<'T>>
    interface IComparable<IAsyncStream<'T>>
    interface IAsyncObservable<'T>
    interface IAsyncBatchObservable<'T>
    interface IAsyncBatchProducer<'T>
    interface IAsyncObserver<'T>
type IAsyncStream<'T> = interface
    interface IAsyncStream
    interface IEquatable<IAsyncStream<'T>>
    interface IComparable<IAsyncStream<'T>>
    interface IAsyncObservable<'T>
    interface IAsyncBatchObservable<'T>
    interface IAsyncBatchProducer<'T>
    interface IAsyncObserver<'T>
Public Interface IAsyncStream(Of T)
Implements IAsyncBatchObserver(Of T), IAsyncObservable(Of T), IAsyncObserver(Of T), IComparable(Of IAsyncStream(Of T)), IEquatable(Of IAsyncStream(Of T)), IStreamIdentity
Public Interface IAsyncStream(Of T)
Implements IAsyncBatchObservable(Of T), IAsyncBatchProducer(Of T), IAsyncObservable(Of T), IAsyncObserver(Of T), IComparable(Of IAsyncStream(Of T)), IEquatable(Of IAsyncStream(Of T)), IStreamIdentity
Public Interface IAsyncStream(Of T)
Implements IAsyncBatchObservable(Of T), IAsyncBatchProducer(Of T), IAsyncObservable(Of T), IAsyncObserver(Of T), IAsyncStream, IComparable(Of IAsyncStream(Of T)), IEquatable(Of IAsyncStream(Of T))

Paramètres de type

T

Type d’objet qui transite par le flux.

Implémente

Propriétés

Guid

Obtient l’identificateur unique.

(Hérité de IStreamIdentity)
IsRewindable

Détermine s’il s’agit d’un flux rembobinable : prend en charge l’abonnement à partir d’un point précédent dans le temps.

Namespace

Obtient l'espace de noms.

(Hérité de IStreamIdentity)
ProviderName

Nom du fournisseur de flux.

StreamId

Obtient l’identificateur de flux.

(Hérité de IAsyncStream)

Méthodes

GetAllSubscriptionHandles()

Récupère une liste de tous les abonnements actifs créés par l’appelant pour ce flux.

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.

(Hérité de IAsyncObserver<T>)
OnErrorAsync(Exception)

Avertit le consommateur que le flux a eu 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.

(Hérité de IAsyncObserver<T>)
OnNextAsync(IList<SequentialItem<T>>)

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

La tâche retournée par cette méthode doit être terminée lorsque le traitement des éléments 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é des articles 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 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é des articles. En particulier, si le fournisseur de flux garantit au moins une livraison, les articles ne doivent pas être considérés comme livrés tant que la tâche retournée par le consommateur n’est pas terminée.

(Hérité de IAsyncBatchObserver<T>)
OnNextAsync(T, StreamSequenceToken)

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.

(Hérité de IAsyncObserver<T>)
OnNextBatchAsync(IEnumerable<T>, StreamSequenceToken)

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

La tâche retournée par cette méthode doit être terminée lorsque tous les éléments du lot ont été suffisamment traités par le consommateur pour répondre à toutes les garanties comportementales.

Autrement dit, la sémantique de la tâche retournée est la même que pour OnNextAsync(T, StreamSequenceToken), étendue pour tous les éléments du lot.

(Hérité de IAsyncBatchProducer<T>)
SubscribeAsync(IAsyncBatchObserver<T>, StreamSequenceToken)

Abonnez un consommateur à ce lot observable.

(Hérité de IAsyncBatchObservable<T>)
SubscribeAsync(IAsyncBatchObserver<T>)

Abonnez un consommateur à ce lot observable.

(Hérité de IAsyncBatchObservable<T>)
SubscribeAsync(IAsyncObserver<T>, StreamSequenceToken, StreamFilterPredicate, Object)

Abonnez un consommateur à cette observable.

(Hérité de IAsyncObservable<T>)
SubscribeAsync(IAsyncObserver<T>, StreamSequenceToken, String)

Abonnez un consommateur à cette observable.

(Hérité de IAsyncObservable<T>)
SubscribeAsync(IAsyncObserver<T>)

Abonnez un consommateur à cette observable.

(Hérité de IAsyncObservable<T>)

Méthodes d’extension

SubscribeAsync<T>(IAsyncBatchObservable<T>, Func<IList<SequentialItem<T>>,Task>, Func<Exception,Task>, Func<Task>)

Abonnez un consommateur à cette observable à l’aide de délégués. Cette méthode est une assistance pour IAsyncBatchObservable.SubscribeAsync permettant à la classe d’abonnement d’inliner les méthodes de gestionnaire au lieu d’exiger une instance d’IAsyncBatchObserver.

SubscribeAsync<T>(IAsyncBatchObservable<T>, Func<IList<SequentialItem<T>>,Task>, Func<Exception,Task>)

Abonnez un consommateur à cette observable à l’aide de délégués. Cette méthode est une assistance pour IAsyncBatchObservable.SubscribeAsync permettant à la classe d’abonnement d’inliner les méthodes de gestionnaire au lieu d’exiger une instance d’IAsyncBatchObserver.

SubscribeAsync<T>(IAsyncBatchObservable<T>, Func<IList<SequentialItem<T>>,Task>, Func<Task>)

Abonnez un consommateur à cette observable à l’aide de délégués. Cette méthode est une assistance pour IAsyncBatchObservable.SubscribeAsync permettant à la classe d’abonnement d’inliner les méthodes de gestionnaire au lieu d’exiger une instance d’IAsyncBatchObserver.

SubscribeAsync<T>(IAsyncBatchObservable<T>, Func<IList<SequentialItem<T>>,Task>)

Abonnez un consommateur à cette observable à l’aide de délégués. Cette méthode est une assistance pour IAsyncBatchObservable.SubscribeAsync permettant à la classe d’abonnement d’inliner les méthodes de gestionnaire au lieu d’exiger une instance d’IAsyncBatchObserver.

SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, StreamSequenceToken, StreamFilterPredicate, Object)

Abonnez un consommateur à cette observable à l’aide de délégués. Cette méthode est une assistance pour IAsyncObservable.SubscribeAsync qui permet à la classe d’abonnement d’inliner les méthodes de gestionnaire au lieu d’exiger une instance d’IAsyncObserver.

SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, StreamSequenceToken)

Abonnez un consommateur à cette observable à l’aide de délégués. Cette méthode est une assistance pour IAsyncObservable.SubscribeAsync qui permet à la classe d’abonnement d’inliner les méthodes de gestionnaire au lieu d’exiger une instance d’IAsyncObserver.

SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, StreamSequenceToken, StreamFilterPredicate, Object)

Abonnez un consommateur à cette observable à l’aide de délégués. Cette méthode est une assistance pour IAsyncObservable.SubscribeAsync qui permet à la classe d’abonnement d’inliner les méthodes de gestionnaire au lieu d’exiger une instance d’IAsyncObserver.

SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, StreamSequenceToken)

Abonnez un consommateur à cette observable à l’aide de délégués. Cette méthode est une assistance pour IAsyncObservable.SubscribeAsync qui permet à la classe d’abonnement d’inliner les méthodes de gestionnaire au lieu d’exiger une instance d’IAsyncObserver.

SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken, Task>, Func<Exception,Task>, Func<Task>, StreamSequenceToken, StreamFilterPredicate, Object)

Abonnez un consommateur à cette observable à l’aide de délégués. Cette méthode est une assistance pour IAsyncObservable.SubscribeAsync qui permet à la classe d’abonnement d’inliner les méthodes de gestionnaire au lieu d’exiger une instance d’IAsyncObserver.

SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, Func<Task>, StreamSequenceToken)

Abonnez un consommateur à cette observable à l’aide de délégués. Cette méthode est une assistance pour IAsyncObservable.SubscribeAsync qui permet à la classe d’abonnement d’inliner les méthodes de gestionnaire au lieu d’exiger une instance d’IAsyncObserver.

SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, Func<Task>)

Abonnez un consommateur à cette observable à l’aide de délégués. Cette méthode est une assistance pour IAsyncObservable.SubscribeAsync qui permet à la classe d’abonnement d’inliner les méthodes de gestionnaire au lieu d’exiger une instance d’IAsyncObserver.

SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>)

Abonnez un consommateur à cette observable à l’aide de délégués. Cette méthode est une assistance pour IAsyncObservable.SubscribeAsync qui permet à la classe d’abonnement d’inliner les méthodes de gestionnaire au lieu d’exiger une instance d’IAsyncObserver.

SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Task>, StreamSequenceToken, StreamFilterPredicate, Object)

Abonnez un consommateur à cette observable à l’aide de délégués. Cette méthode est une assistance pour IAsyncObservable.SubscribeAsync qui permet à la classe d’abonnement d’inliner les méthodes de gestionnaire au lieu d’exiger une instance d’IAsyncObserver.

SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Task>, StreamSequenceToken)

Abonnez un consommateur à cette observable à l’aide de délégués. Cette méthode est une assistance pour IAsyncObservable.SubscribeAsync qui permet à la classe d’abonnement d’inliner les méthodes de gestionnaire au lieu d’exiger une instance d’IAsyncObserver.

SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Task>)

Abonnez un consommateur à cette observable à l’aide de délégués. Cette méthode est une assistance pour IAsyncObservable.SubscribeAsync qui permet à la classe d’abonnement d’inliner les méthodes de gestionnaire au lieu d’exiger une instance d’IAsyncObserver.

SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>)

Abonnez un consommateur à cette observable à l’aide de délégués. Cette méthode est une assistance pour IAsyncObservable.SubscribeAsync qui permet à la classe d’abonnement d’inliner les méthodes de gestionnaire au lieu d’exiger une instance d’IAsyncObserver.

S’applique à