IAsyncBatchObserver<T>.OnNextAsync Метод

Определение

Пространство имен:

Orleans.Streams

Сборка:

Orleans.Streaming.dll

Пакет:

Microsoft.Orleans.Streaming v8.2.0

Передает следующий пакет элементов потребителю.

Задача, возвращаемая этим методом, должна быть завершена, когда обработка элементов была достаточно обработана потребителем для удовлетворения любых гарантий поведения.

Когда потребитель является (конечной точкой производителя) потока, задача завершается, когда реализация потока взяла на себя ответственность за элементы и гарантирует соблюдение своих гарантий доставки. Например, поток, основанный на устойчивой очереди, завершит задачу, когда элементы были надежно сохранены. Поток, который обеспечивает максимальное время доставки, вернет задачу, которая уже завершена.

Когда производитель является (конечной точкой потребителя) потока, задача должна быть завершена кодом потребителя, когда она взяла на себя ответственность за элементы. В частности, если поставщик потоков гарантирует по крайней мере однократную доставку, то элементы не должны рассматриваться до тех пор, пока задача, возвращенная потребителем, не будет завершена.

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

Параметры

items

IList<SequentialItem<T>>

Передаваемый элемент.

Возвращаемое значение

Task

Задача, которая завершается после принятия элемента.