StreamSubscriptionHandle<T> Classe

Definição

Namespace:

Orleans.Streams

Assembly:

Orleans.Streaming.dll

Pacote:

Microsoft.Orleans.Streaming v8.2.0

Identificador que representa essa assinatura. O consumidor pode serializar e armazenar o identificador para cancelar a assinatura posteriormente, por exemplo, em outra ativação nessa granularidade.

[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

Herança

Object

StreamSubscriptionHandle<T>

Atributos

SerializableAttribute GenerateSerializerAttribute

Implementações

IEquatable<StreamSubscriptionHandle<T>>

Construtores

StreamSubscriptionHandle<T>()

Identificador que representa essa assinatura. O consumidor pode serializar e armazenar o identificador para cancelar a assinatura posteriormente, por exemplo, em outra ativação nessa granularidade.

Propriedades

HandleId	Obtém o identificador exclusivo para este StreamSubscriptionHandle
ProviderName	Obtém o nome do provedor.
StreamId	Obtém o identificador de fluxo.

Métodos

Equals(StreamSubscriptionHandle<T>)	Identificador que representa essa assinatura. O consumidor pode serializar e armazenar o identificador para cancelar a assinatura posteriormente, por exemplo, em outra ativação nessa granularidade.
ResumeAsync(IAsyncBatchObserver<T>, StreamSequenceToken)	Retomar o consumo em lote de uma assinatura para um fluxo.
ResumeAsync(IAsyncObserver<T>, StreamSequenceToken)	Consumo retomado de uma assinatura para um fluxo.
UnsubscribeAsync()	Cancele a assinatura de um consumidor de fluxo deste observável.

Métodos de Extensão

ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<T,StreamSequenceToken,Task>, StreamSequenceToken)	Gerada se a função de filtro de fluxo fornecida não for adequada. Normalmente, isso ocorre porque não é um método estático.
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, StreamSequenceToken)	Retoma o consumo de um fluxo usando delegados. Esse método é um auxiliar para StreamSubscriptionHandle.ResumeAsync, permitindo que a classe de assinatura inline os métodos do manipulador em vez de exigir uma instância de IAsyncObserver.
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, Func<Task>, StreamSequenceToken)	Retoma o consumo de um fluxo usando delegados. Esse método é um auxiliar para StreamSubscriptionHandle.ResumeAsync, permitindo que a classe de assinatura inline os métodos do manipulador em vez de exigir uma instância de IAsyncObserver.
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<T,StreamSequenceToken,Task>, Func<Task>, StreamSequenceToken)	Retoma o consumo de um fluxo usando delegados. Esse método é um auxiliar para StreamSubscriptionHandle.ResumeAsync, permitindo que a classe de assinatura inline os métodos do manipulador em vez de exigir uma instância de IAsyncObserver.
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<IList<SequentialItem<T>>,Task>, StreamSequenceToken)	Gerada se a função de filtro de fluxo fornecida não for adequada. Normalmente, isso ocorre porque não é um método estático.
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<IList<SequentialItem<T>>,Task>, Func<Exception,Task>, StreamSequenceToken)	Retoma o consumo de um fluxo usando delegados. Esse método é um auxiliar para StreamSubscriptionHandle.ResumeAsync, permitindo que a classe de assinatura inline os métodos do manipulador em vez de exigir uma instância de IAsyncBatchObserver.
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<IList<SequentialItem<T>>,Task>, Func<Exception,Task>, Func<Task>, StreamSequenceToken)	Retoma o consumo de um fluxo usando delegados. Esse método é um auxiliar para StreamSubscriptionHandle.ResumeAsync, permitindo que a classe de assinatura inline os métodos do manipulador em vez de exigir uma instância de IAsyncBatchObserver.
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<IList<SequentialItem<T>>,Task>, Func<Task>, StreamSequenceToken)	Retoma o consumo de um fluxo usando delegados. Esse método é um auxiliar para StreamSubscriptionHandle.ResumeAsync, permitindo que a classe de assinatura inline os métodos do manipulador em vez de exigir uma instância de IAsyncBatchObserver.