IAsyncObserver<T>.OnNextAsync(T, StreamSequenceToken) Метод

Определение

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

Orleans.Streams

Сборка:

Orleans.Streaming.dll

Пакет:

Microsoft.Orleans.Streaming v8.2.0

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

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

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

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

public System.Threading.Tasks.Task OnNextAsync (T item, Orleans.Streams.StreamSequenceToken? token = default);

abstract member OnNextAsync : 'T * Orleans.Streams.StreamSequenceToken -> System.Threading.Tasks.Task

Public Function OnNextAsync (item As T, Optional token As StreamSequenceToken = Nothing) As Task

Параметры

item

T

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

token

StreamSequenceToken

Токен последовательности потока данного элемента.

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

Task

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