Edit

Share via


IAsyncBatchObserver<T>.OnNextBatchAsync Method

Definition

Passes the next batch of items to the consumer.

The Task returned from this method should be completed when all items in the batch have been sufficiently processed by the consumer to meet any behavioral guarantees.

That is, the semantics of the returned Task is the same as for OnNextAsync, extended for all items in the batch.

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

Parameters

batch
IEnumerable<T>

The items to be passed.

token
StreamSequenceToken

The stream sequence token of this batch of items.

Returns

A Task that is completed when the batch has been accepted.

Applies to