StreamSubscriptionHandle<T> Classe

Définition

Espace de noms:

Orleans.Streams

Assembly:

Orleans.Streaming.dll

Paquet:

Microsoft.Orleans.Streaming v8.2.0

Handle représentant cet abonnement. Le consommateur peut sérialiser et stocker le handle afin de se désabonner ultérieurement, par exemple dans une autre activation sur ce grain.

[System.Serializable]
[Orleans.GenerateSerializer]
public abstract class StreamSubscriptionHandle<T> : IEquatable<Orleans.Streams.StreamSubscriptionHandle<T>>

[<System.Serializable>]
[<Orleans.GenerateSerializer>]
type StreamSubscriptionHandle<'T> = class
    interface IEquatable<StreamSubscriptionHandle<'T>>

Public MustInherit Class StreamSubscriptionHandle(Of T)
Implements IEquatable(Of StreamSubscriptionHandle(Of T))

Paramètres de type

T

Héritage

Object

StreamSubscriptionHandle<T>

Attributs

SerializableAttribute GenerateSerializerAttribute

Implémente

IEquatable<StreamSubscriptionHandle<T>>

Constructeurs

StreamSubscriptionHandle<T>()

Handle représentant cet abonnement. Le consommateur peut sérialiser et stocker le handle afin de se désabonner ultérieurement, par exemple dans une autre activation sur ce grain.

Propriétés

HandleId	Obtient l’identificateur unique de ce StreamSubscriptionHandle
ProviderName	Obtient le nom du fournisseur.
StreamId	Obtient l’identificateur de flux.

Méthodes

Equals(StreamSubscriptionHandle<T>)	Handle représentant cet abonnement. Le consommateur peut sérialiser et stocker le handle afin de se désabonner ultérieurement, par exemple dans une autre activation sur ce grain.
ResumeAsync(IAsyncBatchObserver<T>, StreamSequenceToken)	Reprendre la consommation par lots d’un abonnement vers un flux.
ResumeAsync(IAsyncObserver<T>, StreamSequenceToken)	Reprise de la consommation d’un abonnement vers un flux.
UnsubscribeAsync()	Désabonner un consommateur de flux de cette observable.

Méthodes d’extension

ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<T,StreamSequenceToken,Task>, StreamSequenceToken)	Levée si la fonction de filtre de flux fournie ne convient pas. En règle générale, cela est dû au fait qu’il ne s’agit pas d’une méthode statique.
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, StreamSequenceToken)	Reprend la consommation d’un flux à l’aide de délégués. Cette méthode est une assistance pour StreamSubscriptionHandle.ResumeAsync permettant à la classe d’abonnement d’inliner les méthodes de gestionnaire au lieu d’exiger une instance de IAsyncObserver.
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, Func<Task>, StreamSequenceToken)	Reprend la consommation d’un flux à l’aide de délégués. Cette méthode est une assistance pour StreamSubscriptionHandle.ResumeAsync permettant à la classe d’abonnement d’inliner les méthodes de gestionnaire au lieu d’exiger une instance de IAsyncObserver.
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<T,StreamSequenceToken,Task>, Func<Task>, StreamSequenceToken)	Reprend la consommation d’un flux à l’aide de délégués. Cette méthode est une assistance pour StreamSubscriptionHandle.ResumeAsync permettant à la classe d’abonnement d’inliner les méthodes de gestionnaire au lieu d’exiger une instance de IAsyncObserver.
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<IList<SequentialItem<T>>,Task>, StreamSequenceToken)	Levée si la fonction de filtre de flux fournie ne convient pas. En règle générale, cela est dû au fait qu’il ne s’agit pas d’une méthode statique.
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<IList<SequentialItem<T>>,Task>, Func<Exception,Task>, StreamSequenceToken)	Reprend la consommation d’un flux à l’aide de délégués. Cette méthode est une assistance pour StreamSubscriptionHandle.ResumeAsync permettant à la classe d’abonnement d’inliner les méthodes de gestionnaire au lieu d’exiger une instance de IAsyncBatchObserver.
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<IList<SequentialItem<T>>,Task>, Func<Exception,Task>, Func<Task>, StreamSequenceToken)	Reprend la consommation d’un flux à l’aide de délégués. Cette méthode est une assistance pour StreamSubscriptionHandle.ResumeAsync permettant à la classe d’abonnement d’inliner les méthodes de gestionnaire au lieu d’exiger une instance de IAsyncBatchObserver.
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<IList<SequentialItem<T>>,Task>, Func<Task>, StreamSequenceToken)	Reprend la consommation d’un flux à l’aide de délégués. Cette méthode est une assistance pour StreamSubscriptionHandle.ResumeAsync permettant à la classe d’abonnement d’inliner les méthodes de gestionnaire au lieu d’exiger une instance de IAsyncBatchObserver.