IAsyncBatchProducer<T>.OnNextBatchAsync 方法

定义

命名空间:

Orleans.Streams

程序集:

Orleans.Streaming.dll

包:

Microsoft.Orleans.Streaming v8.2.0

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

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

也就是说，返回的任务的语义与批处理 OnNextAsync(T, StreamSequenceToken)中所有项的扩展相同。

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

参数

batch

IEnumerable<T>

要传递的项。

token

StreamSequenceToken

此项的流序列标记。

返回

Task

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