Edytuj

Udostępnij za pośrednictwem

IAsyncBatchProducer<T>.OnNextBatchAsync Method

  • Reference

Definition

Namespace:
Orleans.Streams
Assembly:
Orleans.Core.Abstractions.dll
Assembly:
Orleans.Streaming.dll
Package:
Microsoft.Orleans.Core.Abstractions v2.4.5
Package:
Microsoft.Orleans.Core.Abstractions v3.6.5
Package:
Microsoft.Orleans.Streaming v7.2.5
Package:
Microsoft.Orleans.Streaming v8.0.0
Package:
Microsoft.Orleans.Streaming v8.1.0
Package:
Microsoft.Orleans.Streaming v8.2.0
Source:
IAsyncBatchProducer.cs

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(T, StreamSequenceToken), extended for all items in the batch. 

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

Parameters

batch
IEnumerable<T>

The items to be passed.

token
StreamSequenceToken

The stream sequence token of this item.

Returns

Task

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

Applies to