IAsyncStream<T> Interfaz

Definición

Espacio de nombres:

Orleans.Streams

Ensamblado:

Orleans.Streaming.dll

Paquete:

Microsoft.Orleans.Streaming v8.2.0

Esta interfaz representa un objeto que actúa como encuentro distribuido entre productores y consumidores. Es similar a un marco Subject reactivo e implementa IObserver ni IObservable interfaces.

public interface IAsyncStream<T> : IComparable<Orleans.Streams.IAsyncStream<T>>, IEquatable<Orleans.Streams.IAsyncStream<T>>, Orleans.Streams.IAsyncBatchObservable<T>, Orleans.Streams.IAsyncBatchProducer<T>, Orleans.Streams.IAsyncObservable<T>, Orleans.Streams.IAsyncObserver<T>, Orleans.Streams.IAsyncStream

type IAsyncStream<'T> = interface
    interface IAsyncStream
    interface IEquatable<IAsyncStream<'T>>
    interface IComparable<IAsyncStream<'T>>
    interface IAsyncObservable<'T>
    interface IAsyncBatchObservable<'T>
    interface IAsyncBatchProducer<'T>
    interface IAsyncObserver<'T>

Public Interface IAsyncStream(Of T)
Implements IAsyncBatchObservable(Of T), IAsyncBatchProducer(Of T), IAsyncObservable(Of T), IAsyncObserver(Of T), IAsyncStream, IComparable(Of IAsyncStream(Of T)), IEquatable(Of IAsyncStream(Of T))

Parámetros de tipo

T

Tipo de objeto que fluye a través de la secuencia.

Implementaciones

IAsyncObservable<T> IAsyncObserver<T> IComparable<IAsyncStream<T>> IEquatable<IAsyncStream<T>> IAsyncBatchObservable<T> IAsyncBatchProducer<T> IAsyncStream

Propiedades

StreamId

Obtiene el identificador de secuencia. (Heredado de IAsyncStream)

Métodos

GetAllSubscriptionHandles()	Recupera una lista de todas las suscripciones activas creadas por el autor de la llamada para esta secuencia.
OnCompletedAsync()	Notifica al consumidor que se completó la secuencia. La tarea devuelta desde este método debe completarse cuando el consumidor haya terminado de procesar el cierre de la secuencia. (Heredado de IAsyncObserver<T>)
OnErrorAsync(Exception)	Notifica al consumidor que la secuencia tenía un error. La tarea devuelta desde este método debe completarse cuando el consumidor haya terminado de procesar el cierre de la secuencia. (Heredado de IAsyncObserver<T>)
OnNextAsync(T, StreamSequenceToken)	Pasa el siguiente elemento al consumidor. La tarea devuelta desde este método debe completarse cuando el consumidor haya procesado lo suficiente el procesamiento del elemento para cumplir cualquier garantía de comportamiento. Cuando el consumidor es el (punto de conexión de productor de) una secuencia, la tarea se completa cuando la implementación de la secuencia ha aceptado la responsabilidad del elemento y está garantizada de cumplir sus garantías de entrega. Por ejemplo, una secuencia basada en una cola duradera completaría la tarea cuando el elemento se haya guardado de forma duradera. Una secuencia que proporciona el máximo esfuerzo una vez que la entrega devuelve una tarea que ya está completa. Cuando el productor es el (punto de conexión de consumidor de) una secuencia, el código de consumidor debe completar la tarea cuando haya aceptado la responsabilidad del elemento. En concreto, si el proveedor de flujos garantiza la entrega al menos una vez, el artículo no se debe considerar entregado hasta que se haya completado la tarea devuelta por el consumidor. (Heredado de IAsyncObserver<T>)
OnNextBatchAsync(IEnumerable<T>, StreamSequenceToken)	Pasa el siguiente lote de elementos al consumidor. La tarea devuelta desde este método debe completarse cuando el consumidor haya procesado suficientemente todos los elementos del lote para cumplir las garantías de comportamiento. Es decir, la semántica de la tarea devuelta es la misma que para OnNextAsync(T, StreamSequenceToken), extendida para todos los elementos del lote. (Heredado de IAsyncBatchProducer<T>)
SubscribeAsync(IAsyncBatchObserver<T>, StreamSequenceToken)	Suscríbase a un consumidor a este lote observable. (Heredado de IAsyncBatchObservable<T>)
SubscribeAsync(IAsyncBatchObserver<T>)	Suscríbase a un consumidor a este lote observable. (Heredado de IAsyncBatchObservable<T>)
SubscribeAsync(IAsyncObserver<T>, StreamSequenceToken, String)	Suscríbase a un consumidor a este observable. (Heredado de IAsyncObservable<T>)
SubscribeAsync(IAsyncObserver<T>)	Suscríbase a un consumidor a este observable. (Heredado de IAsyncObservable<T>)

Métodos de extensión

SubscribeAsync<T>(IAsyncBatchObservable<T>, Func<IList<SequentialItem<T>>,Task>, Func<Exception,Task>, Func<Task>)	Suscríbase a 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 a 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 a 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 a 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>(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>, 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>, 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>)	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.
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>)	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.