IAsyncBatchObservable<T>.SubscribeAsync Método

Definición

Espacio de nombres:

Orleans.Streams

Ensamblado:

Orleans.Streaming.dll

Paquete:

Microsoft.Orleans.Streaming v8.2.0

Sobrecargas

SubscribeAsync(IAsyncBatchObserver<T>)	Suscríbase un consumidor a este lote observable.
SubscribeAsync(IAsyncBatchObserver<T>, StreamSequenceToken)	Suscríbase un consumidor a este lote observable.

SubscribeAsync(IAsyncBatchObserver<T>)

Suscríbase un consumidor a este lote observable.

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>

Observador de lotes asincrónico que se va a suscribir.

Devoluciones

Task<StreamSubscriptionHandle<T>>

Promesa de streamSubscriptionHandle que representa la suscripción. El consumidor puede cancelar la suscripción mediante este identificador. La suscripción permanece activa siempre que no se cancele explícitamente.

SubscribeAsync(IAsyncBatchObserver<T>, StreamSequenceToken)

Suscríbase un consumidor a este lote observable.

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>

Observador de lotes asincrónico que se va a suscribir.

token

StreamSequenceToken

Secuencia de secuencia desde la que se va a usar como desplazamiento para iniciar la suscripción.

Devoluciones

Task<StreamSubscriptionHandle<T>>

Promesa de streamSubscriptionHandle que representa la suscripción. El consumidor puede cancelar la suscripción mediante este identificador. La suscripción permanece activa siempre que no se cancele explícitamente.