IAsyncBatchObserver<T>.OnNextBatchAsync 方法

定义

命名空间:

Orleans.Streams

程序集:

Orleans.dll

包:

Microsoft.Orleans.Core v1.5.10

将下一批项目传递给使用者。

当使用者已足够处理批处理中的所有项以满足任何行为保证时，应完成此方法返回的任务。

也就是说，返回的任务的语义与 OnNextAsync批处理中所有项的语义相同。

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

参数

batch

IEnumerable<T>

要传递的项。

token

StreamSequenceToken

此批项的流序列标记。

返回

Task

一个在接受批处理时完成的任务。