Edit

Share via


IAsyncBatchObserver<T>.OnNextAsync Method

Definition

Passes the next batch of items to the consumer.

The Task returned from this method should be completed when the items' processing has been sufficiently processed by the consumer to meet any behavioral guarantees.

When the consumer is the (producer endpoint of) a stream, the Task is completed when the stream implementation has accepted responsibility for the items and is assured of meeting its delivery guarantees. For instance, a stream based on a durable queue would complete the Task when the items have been durably saved. A stream that provides best-effort at most once delivery would return a Task that is already complete.

When the producer is the (consumer endpoint of) a stream, the Task should be completed by the consumer code when it has accepted responsibility for the items. In particular, if the stream provider guarantees at-least-once delivery, then the items should not be considered delivered until the Task returned by the consumer has been completed.

public System.Threading.Tasks.Task OnNextAsync (System.Collections.Generic.IList<Orleans.Streams.SequentialItem<T>> items);
abstract member OnNextAsync : System.Collections.Generic.IList<Orleans.Streams.SequentialItem<'T>> -> System.Threading.Tasks.Task
Public Function OnNextAsync (items As IList(Of SequentialItem(Of T))) As Task

Parameters

items
IList<SequentialItem<T>>

The item to be passed.

Returns

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

Applies to