IAsyncBatchObserver<T>.OnNextAsync 方法

定义

命名空间:

Orleans.Streams

程序集:

Orleans.Streaming.dll

包:

Microsoft.Orleans.Streaming v8.2.0

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

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

当使用者是流) 流的 (生成方终结点时，当流实现已接受对项目负责并保证满足其交付保证时，任务将完成。 例如，当项被持久保存时，基于持久队列的流将完成任务。 一个流，最多一次提供一次最费力的流将返回已完成的任务。

当生成者是) 流的 (使用者终结点时，当任务接受对项的责任时，应由使用者代码完成。 具体而言，如果流提供程序保证至少传递一次，则在使用者返回的任务完成之前，不应将项目视为传递。

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

参数

items

IList<SequentialItem<T>>

要传递的项。

返回

Task

一个在项目被接受时完成的任务。