IAsyncObserver<T>.OnNextAsync(T, StreamSequenceToken) 方法

定义

将下一项传递给使用者。

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

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

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

public System.Threading.Tasks.Task OnNextAsync (T item, Orleans.Streams.StreamSequenceToken token = default);
public System.Threading.Tasks.Task OnNextAsync (T item, Orleans.Streams.StreamSequenceToken? token = default);
abstract member OnNextAsync : 'T * Orleans.Streams.StreamSequenceToken -> System.Threading.Tasks.Task
Public Function OnNextAsync (item As T, Optional token As StreamSequenceToken = Nothing) As Task

参数

item
T

要传递的项。

token
StreamSequenceToken

此项的流序列标记。

返回

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

适用于