Поделиться через

IAsyncBatchObserver<T>.OnNextBatchAsync Метод

  • Ссылка

Определение

Пространство имен:
Orleans.Streams
Сборка:
Orleans.dll
Пакет:
Microsoft.Orleans.Core v1.5.10

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

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

То есть семантика возвращаемой задачи аналогична OnNextAsyncсемантике для всех элементов в пакете. 

public System.Threading.Tasks.Task OnNextBatchAsync (System.Collections.Generic.IEnumerable<in T> batch, Orleans.Streams.StreamSequenceToken token = default);
abstract member OnNextBatchAsync : seq<'T> * Orleans.Streams.StreamSequenceToken -> System.Threading.Tasks.Task
Public Function OnNextBatchAsync (batch As IEnumerable(Of In T), Optional token As StreamSequenceToken = Nothing) As Task

Параметры

batch
IEnumerable<T>

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

token
StreamSequenceToken

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

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

Task

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

Применяется к