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

IAsyncBatchProducer<T>.OnNextBatchAsync Метод

  • Ссылка

Определение

Пространство имен:
Orleans.Streams
Сборка:
Orleans.Core.Abstractions.dll
Сборка:
Orleans.Streaming.dll
Пакет:
Microsoft.Orleans.Core.Abstractions v2.4.5
Пакет:
Microsoft.Orleans.Core.Abstractions v3.6.5
Пакет:
Microsoft.Orleans.Streaming v7.2.5
Пакет:
Microsoft.Orleans.Streaming v8.0.0
Пакет:
Microsoft.Orleans.Streaming v8.1.0
Пакет:
Microsoft.Orleans.Streaming v8.2.0
Исходный код:
IAsyncBatchProducer.cs

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

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

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

public System.Threading.Tasks.Task OnNextBatchAsync (System.Collections.Generic.IEnumerable<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 T), Optional token As StreamSequenceToken = Nothing) As Task

Параметры

batch
IEnumerable<T>

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

token
StreamSequenceToken

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

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

Task

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

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