Skip to content
Orleans logoMicrosoft Orleans

IAsyncBatchProducer<T>

interface

Namespace: Orleans.Streams

This interface generalizes the IAsyncObserver interface to allow production of batches of items.

Note that this interface is invoked (used) by item producers. 

public interface IAsyncBatchProducer<T> : IAsyncObserver<T>

Methods

  • OnNextBatchAsync(IEnumerable<T>, StreamSequenceToken) 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.