StreamSubscriptionHandle<T> Clase

Definición

Espacio de nombres:

Orleans.Streams

Ensamblado:

Orleans.Streaming.dll

Paquete:

Microsoft.Orleans.Streaming v8.1.0

Identificador que representa esta suscripción. El consumidor puede serializar y almacenar el identificador para cancelar la suscripción más adelante, por ejemplo, en otra activación en este grano.

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

Parámetros de tipo

T

Herencia

Object

StreamSubscriptionHandle<T>

Atributos

SerializableAttribute GenerateSerializerAttribute

Implementaciones

IEquatable<StreamSubscriptionHandle<T>>

Constructores

StreamSubscriptionHandle<T>()

Identificador que representa esta suscripción. El consumidor puede serializar y almacenar el identificador para cancelar la suscripción más adelante, por ejemplo, en otra activación en este grano.

Propiedades

HandleId	Obtiene el identificador único de este StreamSubscriptionHandle.
ProviderName	Obtiene el nombre del proveedor.
StreamId	Obtiene el identificador de secuencia.

Métodos

Equals(StreamSubscriptionHandle<T>)	Identificador que representa esta suscripción. El consumidor puede serializar y almacenar el identificador para cancelar la suscripción más adelante, por ejemplo, en otra activación en este grano.
ResumeAsync(IAsyncBatchObserver<T>, StreamSequenceToken)	Reanude el consumo por lotes de una suscripción a una secuencia.
ResumeAsync(IAsyncObserver<T>, StreamSequenceToken)	Se reanudó el consumo de una suscripción a una secuencia.
UnsubscribeAsync()	Cancela la suscripción de un consumidor de secuencias de este observable.

Métodos de extensión

ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<T,StreamSequenceToken,Task>, StreamSequenceToken)	Se produce si la función de filtro de flujo proporcionada no es adecuada. Normalmente, esto se debe a que no es un método estático.
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, StreamSequenceToken)	Reanuda el consumo de una secuencia mediante delegados. Este método es un asistente para streamSubscriptionHandle.ResumeAsync que permite que la clase de suscripción inserte los métodos de controlador en lugar de requerir una instancia de IAsyncObserver.
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, Func<Task>, StreamSequenceToken)	Reanuda el consumo de una secuencia mediante delegados. Este método es un asistente para streamSubscriptionHandle.ResumeAsync que permite que la clase de suscripción inserte los métodos de controlador en lugar de requerir una instancia de IAsyncObserver.
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<T,StreamSequenceToken,Task>, Func<Task>, StreamSequenceToken)	Reanuda el consumo de una secuencia mediante delegados. Este método es un asistente para streamSubscriptionHandle.ResumeAsync que permite que la clase de suscripción inserte los métodos de controlador en lugar de requerir una instancia de IAsyncObserver.
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<IList<SequentialItem<T>>,Task>, StreamSequenceToken)	Se produce si la función de filtro de flujo proporcionada no es adecuada. Normalmente, esto se debe a que no es un método estático.
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<IList<SequentialItem<T>>,Task>, Func<Exception,Task>, StreamSequenceToken)	Reanuda el consumo de una secuencia mediante delegados. Este método es un asistente para streamSubscriptionHandle.ResumeAsync que permite que la clase de suscripción inserte los métodos de controlador en lugar de requerir una instancia de IAsyncBatchObserver.
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<IList<SequentialItem<T>>,Task>, Func<Exception,Task>, Func<Task>, StreamSequenceToken)	Reanuda el consumo de una secuencia mediante delegados. Este método es un asistente para streamSubscriptionHandle.ResumeAsync que permite que la clase de suscripción inserte los métodos de controlador en lugar de requerir una instancia de IAsyncBatchObserver.
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<IList<SequentialItem<T>>,Task>, Func<Task>, StreamSequenceToken)	Reanuda el consumo de una secuencia mediante delegados. Este método es un asistente para streamSubscriptionHandle.ResumeAsync que permite que la clase de suscripción inserte los métodos de controlador en lugar de requerir una instancia de IAsyncBatchObserver.