IAsyncBatchObservable<T>.SubscribeAsync Método

Definição

Namespace:

Orleans.Streams

Assembly:

Orleans.Streaming.dll

Pacote:

Microsoft.Orleans.Streaming v8.2.0

Sobrecargas

SubscribeAsync(IAsyncBatchObserver<T>)	Assine um consumidor para este lote observável.
SubscribeAsync(IAsyncBatchObserver<T>, StreamSequenceToken)	Assine um consumidor para este lote observável.

SubscribeAsync(IAsyncBatchObserver<T>)

Assine um consumidor para este lote observável.

public System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync (Orleans.Streams.IAsyncBatchObserver<T> observer);

abstract member SubscribeAsync : Orleans.Streams.IAsyncBatchObserver<'T> -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>>

Public Function SubscribeAsync (observer As IAsyncBatchObserver(Of T)) As Task(Of StreamSubscriptionHandle(Of T))

Parâmetros

observer

IAsyncBatchObserver<T>

O observador de lote assíncrono a ser assinado.

Retornos

Task<StreamSubscriptionHandle<T>>

Uma promessa para um StreamSubscriptionHandle que representa a assinatura. O consumidor pode cancelar a assinatura usando esse identificador. A assinatura permanece ativa desde que não seja explicitamente cancelada.

SubscribeAsync(IAsyncBatchObserver<T>, StreamSequenceToken)

Assine um consumidor para este lote observável.

public System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync (Orleans.Streams.IAsyncBatchObserver<T> observer, Orleans.Streams.StreamSequenceToken? token);

abstract member SubscribeAsync : Orleans.Streams.IAsyncBatchObserver<'T> * Orleans.Streams.StreamSequenceToken -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>>

Public Function SubscribeAsync (observer As IAsyncBatchObserver(Of T), token As StreamSequenceToken) As Task(Of StreamSubscriptionHandle(Of T))

Parâmetros

observer

IAsyncBatchObserver<T>

O observador de lote assíncrono a ser assinado.

token

StreamSequenceToken

A sequência de fluxo a ser usada como um deslocamento para iniciar a assinatura.

Retornos

Task<StreamSubscriptionHandle<T>>

Uma promessa para um StreamSubscriptionHandle que representa a assinatura. O consumidor pode cancelar a assinatura usando esse identificador. A assinatura permanece ativa desde que não seja explicitamente cancelada.