IAsyncBatchProducer<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 de lotes de elementos.

Tenga en cuenta que los productores de elementos invocan (usan) esta interfaz.

public interface IAsyncBatchProducer<T> : Orleans.Streams.IAsyncObserver<T>

type IAsyncBatchProducer<'T> = interface
    interface IAsyncObserver<'T>

Public Interface IAsyncBatchProducer(Of T)
Implements IAsyncObserver(Of T)

Parámetros de tipo

T

Tipo de objeto consumido por el observador.

Derivado

Orleans.Streams.IAsyncStream<T>

Implementaciones

IAsyncObserver<T>

Métodos

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 tuvo 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 suficientemente el procesamiento del elemento para cumplir las garantías de comportamiento. Cuando el consumidor es el (punto de conexión de productor de) una secuencia, la tarea se completa cuando la implementación del flujo 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 proporcione el mejor esfuerzo una vez que la entrega devuelva 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 secuencias garantiza la entrega al menos una vez, el elemento 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 todos los elementos del lote de forma suficiente 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.