IAsyncBatchObservable<T> Interfaz

Definición

Espacio de nombres:

Orleans.Streams

Ensamblado:

Orleans.Streaming.dll

Paquete:

Microsoft.Orleans.Streaming v8.2.0

Esta interfaz generaliza la interfaz IAsyncObserver para permitir la producción y el consumo de lotes de elementos.

Tenga en cuenta que esta interfaz la implementan los consumidores de elementos e invocan (usan) los productores de elementos. Esto significa que el punto de conexión de consumidor de una secuencia implementa esta interfaz.

public interface IAsyncBatchObservable<T>

type IAsyncBatchObservable<'T> = interface

Public Interface IAsyncBatchObservable(Of T)

Parámetros de tipo

T

Tipo de objeto consumido por el observador.

Derivado

Orleans.Streams.IAsyncStream<T>

Métodos

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

Métodos de extensión

SubscribeAsync<T>(IAsyncBatchObservable<T>, Func<IList<SequentialItem<T>>,Task>, Func<Exception,Task>, Func<Task>)	Suscríbase un consumidor a este observable mediante delegados. Este método es un asistente para IAsyncBatchObservable.SubscribeAsync que permite a la clase de suscripción insertar los métodos de controlador en lugar de requerir una instancia de IAsyncBatchObserver.
SubscribeAsync<T>(IAsyncBatchObservable<T>, Func<IList<SequentialItem<T>>,Task>, Func<Exception,Task>)	Suscríbase un consumidor a este observable mediante delegados. Este método es un asistente para IAsyncBatchObservable.SubscribeAsync que permite a la clase de suscripción insertar los métodos de controlador en lugar de requerir una instancia de IAsyncBatchObserver.
SubscribeAsync<T>(IAsyncBatchObservable<T>, Func<IList<SequentialItem<T>>,Task>, Func<Task>)	Suscríbase un consumidor a este observable mediante delegados. Este método es un asistente para IAsyncBatchObservable.SubscribeAsync que permite a la clase de suscripción insertar los métodos de controlador en lugar de requerir una instancia de IAsyncBatchObserver.
SubscribeAsync<T>(IAsyncBatchObservable<T>, Func<IList<SequentialItem<T>>,Task>)	Suscríbase un consumidor a este observable mediante delegados. Este método es un asistente para IAsyncBatchObservable.SubscribeAsync que permite a la clase de suscripción insertar los métodos de controlador en lugar de requerir una instancia de IAsyncBatchObserver.