IAsyncBatchObserver<T>.OnNextAsync Método

Definición

Espacio de nombres:

Orleans.Streams

Ensamblado:

Orleans.Streaming.dll

Paquete:

Microsoft.Orleans.Streaming v8.1.0

Pasa el siguiente lote de elementos al consumidor.

La tarea devuelta desde este método debe completarse cuando el consumidor haya procesado lo suficiente el procesamiento de los elementos 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 de la secuencia ha aceptado la responsabilidad de los elementos y está garantizada de cumplir sus garantías de entrega. Por ejemplo, una secuencia basada en una cola duradera completaría la tarea cuando los elementos se hayan 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 de los elementos. En concreto, si el proveedor de flujos garantiza la entrega al menos una vez, los elementos no se deben considerar entregados hasta que se haya completado la tarea devuelta por el consumidor.

public System.Threading.Tasks.Task OnNextAsync (System.Collections.Generic.IList<Orleans.Streams.SequentialItem<T>> items);

abstract member OnNextAsync : System.Collections.Generic.IList<Orleans.Streams.SequentialItem<'T>> -> System.Threading.Tasks.Task

Public Function OnNextAsync (items As IList(Of SequentialItem(Of T))) As Task

Parámetros

items

IList<SequentialItem<T>>

Elemento que se va a pasar.

Devoluciones

Task

Tarea que se completa cuando se ha aceptado el elemento.