OnNextBatchAsync(IEnumerable<T>, StreamSequenceToken)
abstract
public abstract Task OnNextBatchAsync(IEnumerable<T> batch, StreamSequenceToken token = null) 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 Orleans.Streams.IAsyncObserver.OnNextAsync, extended for all items in the batch.
Parameters
batchIEnumerable<T>- The items to be passed.
tokenStreamSequenceToken- The stream sequence token of this item.
Returns
A Task that is completed when the batch has been accepted.