IAsyncObserver<T>.OnNextAsync(T, StreamSequenceToken) 方法
定义
重要
一些信息与预发行产品相关,相应产品在发行之前可能会进行重大修改。 对于此处提供的信息,Microsoft 不作任何明示或暗示的担保。
将下一项传递给使用者。
当使用者已充分处理项目处理以满足任何行为保证时,应完成此方法返回的任务。
当使用者是流) 流的 (生成者终结点时,当流实现已接受对项目负责并保证满足其交付保证时,任务将完成。 例如,当项被持久保存时,基于持久队列的流将完成任务。 一个流,最多一次提供一次最费力的流将返回已完成的任务。
当生成者是) 流的 (使用者终结点时,该任务应由使用者代码完成,届时该任务应由使用者代码负责。 具体而言,如果流提供程序保证至少传递一次,则在使用者返回的任务完成之前,不应将项目视为传递。
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
此项的流序列标记。
返回
一个在项目被接受时完成的任务。