StreamSubscriptionHandle<T> Classe

Definizione

Spazio dei nomi:

Orleans.Streams

Assembly:

Orleans.Streaming.dll

Pacchetto:

Microsoft.Orleans.Streaming v8.2.0

Handle che rappresenta questa sottoscrizione. Il consumer può serializzare e archiviare l'handle per annullare la sottoscrizione in un secondo momento, ad esempio in un'altra attivazione in base a questa granularità.

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

Parametri di tipo

T

Ereditarietà

Object

StreamSubscriptionHandle<T>

Attributi

SerializableAttribute GenerateSerializerAttribute

Implementazioni

IEquatable<StreamSubscriptionHandle<T>>

Costruttori

StreamSubscriptionHandle<T>()

Handle che rappresenta questa sottoscrizione. Il consumer può serializzare e archiviare l'handle per annullare la sottoscrizione in un secondo momento, ad esempio in un'altra attivazione in base a questa granularità.

Proprietà

HandleId	Ottiene l'identificatore univoco per questo oggetto StreamSubscriptionHandle
ProviderName	Ottiene il nome del provider.
StreamId	Ottiene l'identificatore del flusso.

Metodi

Equals(StreamSubscriptionHandle<T>)	Handle che rappresenta questa sottoscrizione. Il consumer può serializzare e archiviare l'handle per annullare la sottoscrizione in un secondo momento, ad esempio in un'altra attivazione in base a questa granularità.
ResumeAsync(IAsyncBatchObserver<T>, StreamSequenceToken)	Riprendere l'utilizzo batch da una sottoscrizione a un flusso.
ResumeAsync(IAsyncObserver<T>, StreamSequenceToken)	Ripreso dell'utilizzo da una sottoscrizione a un flusso.
UnsubscribeAsync()	Annullare la sottoscrizione di un consumer di flusso a questo oggetto osservabile.

Metodi di estensione

ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<T,StreamSequenceToken,Task>, StreamSequenceToken)	Generata se la funzione di filtro del flusso fornita non è adatta. In genere ciò è dovuto al fatto che non è un metodo statico.
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, StreamSequenceToken)	Riprende l'utilizzo di un flusso usando i delegati. Questo metodo è un helper per StreamSubscriptionHandle.ResumeAsync che consente alla classe di sottoscrizione di inline i metodi del gestore anziché richiedere un'istanza di IAsyncObserver.
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, Func<Task>, StreamSequenceToken)	Riprende l'utilizzo di un flusso usando i delegati. Questo metodo è un helper per StreamSubscriptionHandle.ResumeAsync che consente alla classe di sottoscrizione di inline i metodi del gestore anziché richiedere un'istanza di IAsyncObserver.
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<T,StreamSequenceToken,Task>, Func<Task>, StreamSequenceToken)	Riprende l'utilizzo di un flusso usando i delegati. Questo metodo è un helper per StreamSubscriptionHandle.ResumeAsync che consente alla classe di sottoscrizione di inline i metodi del gestore anziché richiedere un'istanza di IAsyncObserver.
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<IList<SequentialItem<T>>,Task>, StreamSequenceToken)	Generata se la funzione di filtro del flusso fornita non è adatta. In genere ciò è dovuto al fatto che non è un metodo statico.
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<IList<SequentialItem<T>>,Task>, Func<Exception,Task>, StreamSequenceToken)	Riprende l'utilizzo di un flusso usando i delegati. Questo metodo è un helper per StreamSubscriptionHandle.ResumeAsync che consente alla classe di sottoscrizione di inline i metodi del gestore anziché richiedere un'istanza di IAsyncBatchObserver.
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<IList<SequentialItem<T>>,Task>, Func<Exception,Task>, Func<Task>, StreamSequenceToken)	Riprende l'utilizzo di un flusso usando i delegati. Questo metodo è un helper per StreamSubscriptionHandle.ResumeAsync che consente alla classe di sottoscrizione di inline i metodi del gestore anziché richiedere un'istanza di IAsyncBatchObserver.
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<IList<SequentialItem<T>>,Task>, Func<Task>, StreamSequenceToken)	Riprende l'utilizzo di un flusso usando i delegati. Questo metodo è un helper per StreamSubscriptionHandle.ResumeAsync che consente alla classe di sottoscrizione di inline i metodi del gestore anziché richiedere un'istanza di IAsyncBatchObserver.