IAsyncObserver<T> 接口

定义

此接口通用化标准 .NET IObserver 接口,以允许异步生产项。

请注意,此接口由项使用者实现,并且由项目生成者) 使用的 (调用。 这意味着流的使用者终结点实现此接口。

public interface IAsyncObserver<in T>
type IAsyncObserver<'T> = interface
Public Interface IAsyncObserver(Of In T)

类型参数

T

观察者使用的对象的类型。

这是逆变类型参数。 即,可以使用指定的类型,也可以使用派生程度较低的任何类型。 有关协变和逆变的详细信息,请参阅泛型中的协变和逆变
派生

方法

OnCompletedAsync()

通知使用者流已完成。

当使用者完成处理流关闭时,应完成从此方法返回的任务。

OnErrorAsync(Exception)

通知使用者流出错。

当使用者完成处理流关闭时,应完成从此方法返回的任务。

OnNextAsync(T, StreamSequenceToken)

将下一项传递给使用者。

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

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

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

适用于