IAsyncObservable<T> Interfaz

Definición

Espacio de nombres:

Orleans.Streams

Ensamblado:

Orleans.Streaming.dll

Paquete:

Microsoft.Orleans.Streaming v8.1.0

Esta interfaz generaliza la interfaz IObserveable estándar de .NET para permitir el consumo asincrónico de elementos. Asincrónico aquí significa que el consumidor puede procesar los elementos de forma asincrónica y indicar la finalización de elementos al productor completando la tarea devuelta.

Tenga en cuenta que los consumidores de elementos invocan (usan) esta interfaz y la implementan los productores de artículos. Esto significa que el punto de conexión del productor de una secuencia implementa esta interfaz.

public interface IAsyncObservable<T>

type IAsyncObservable<'T> = interface

Public Interface IAsyncObservable(Of T)

Parámetros de tipo

T

Tipo de objeto generado por el observable.

Derivado

Orleans.Streams.IAsyncStream<T>

Métodos

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

Métodos de extensión

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