StreamSubscriptionHandle<T> Klasse

Definition

Namespace:

Orleans.Streams

Assembly:

Orleans.Streaming.dll

Paket:

Microsoft.Orleans.Streaming v8.2.0

Handle, der dieses Abonnement darstellt. Der Consumer kann den Handle serialisieren und speichern, um sich später abzumelden, z. B. bei einer anderen Aktivierung für dieses Körnchen.

[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))

Typparameter

T

Vererbung

Object

StreamSubscriptionHandle<T>

Attribute

SerializableAttribute GenerateSerializerAttribute

Implementiert

IEquatable<StreamSubscriptionHandle<T>>

Konstruktoren

StreamSubscriptionHandle<T>()

Handle, der dieses Abonnement darstellt. Der Consumer kann den Handle serialisieren und speichern, um sich später abzumelden, z. B. bei einer anderen Aktivierung für dieses Körnchen.

Eigenschaften

HandleId	Ruft den eindeutigen Bezeichner für dieses StreamSubscriptionHandle ab.
ProviderName	Ruft den Namen des Anbieters ab.
StreamId	Ruft den Streambezeichner ab.

Methoden

Equals(StreamSubscriptionHandle<T>)	Handle, der dieses Abonnement darstellt. Der Consumer kann den Handle serialisieren und speichern, um sich später abzumelden, z. B. bei einer anderen Aktivierung für dieses Körnchen.
ResumeAsync(IAsyncBatchObserver<T>, StreamSequenceToken)	Setzen Sie die Batchnutzung von einem Abonnement in einen Stream fort.
ResumeAsync(IAsyncObserver<T>, StreamSequenceToken)	Die Nutzung von einem Abonnement zu einem Stream wurde fortgesetzt.
UnsubscribeAsync()	Abmelden eines Stream-Consumers von dieser Beobachtung.

Erweiterungsmethoden

ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<T,StreamSequenceToken,Task>, StreamSequenceToken)	Wird ausgelöst, wenn die bereitgestellte Streamfilterfunktion nicht geeignet ist. In der Regel liegt dies daran, dass es sich nicht um eine statische Methode handelt.
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, StreamSequenceToken)	Setzt die Nutzung eines Streams mithilfe von Delegaten fort. Diese Methode ist ein Hilfsprogramm für streamSubscriptionHandle.ResumeAsync, sodass die abonnierende Klasse die Handlermethoden inline einordnet, anstatt eine Instanz von IAsyncObserver zu erfordern.
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, Func<Task>, StreamSequenceToken)	Setzt die Nutzung eines Streams mithilfe von Delegaten fort. Diese Methode ist ein Hilfsprogramm für streamSubscriptionHandle.ResumeAsync, sodass die abonnierende Klasse die Handlermethoden inline einordnet, anstatt eine Instanz von IAsyncObserver zu erfordern.
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<T,StreamSequenceToken,Task>, Func<Task>, StreamSequenceToken)	Setzt die Nutzung eines Streams mithilfe von Delegaten fort. Diese Methode ist ein Hilfsprogramm für streamSubscriptionHandle.ResumeAsync, sodass die abonnierende Klasse die Handlermethoden inline einordnet, anstatt eine Instanz von IAsyncObserver zu erfordern.
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<IList<SequentialItem<T>>,Task>, StreamSequenceToken)	Wird ausgelöst, wenn die bereitgestellte Streamfilterfunktion nicht geeignet ist. In der Regel liegt dies daran, dass es sich nicht um eine statische Methode handelt.
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<IList<SequentialItem<T>>,Task>, Func<Exception,Task>, StreamSequenceToken)	Setzt die Nutzung eines Streams mithilfe von Delegaten fort. Diese Methode ist ein Hilfsprogramm für streamSubscriptionHandle.ResumeAsync, sodass die abonnierende Klasse die Handlermethoden inline einordnet, anstatt eine Instanz von IAsyncBatchObserver zu benötigen.
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<IList<SequentialItem<T>>,Task>, Func<Exception,Task>, Func<Task>, StreamSequenceToken)	Setzt die Nutzung eines Streams mithilfe von Delegaten fort. Diese Methode ist ein Hilfsprogramm für streamSubscriptionHandle.ResumeAsync, sodass die abonnierende Klasse die Handlermethoden inline einordnet, anstatt eine Instanz von IAsyncBatchObserver zu benötigen.
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<IList<SequentialItem<T>>,Task>, Func<Task>, StreamSequenceToken)	Setzt die Nutzung eines Streams mithilfe von Delegaten fort. Diese Methode ist ein Hilfsprogramm für streamSubscriptionHandle.ResumeAsync, sodass die abonnierende Klasse die Handlermethoden inline einordnet, anstatt eine Instanz von IAsyncBatchObserver zu benötigen.