IAsyncBatchProducer<T> 接口

定义

命名空间:

Orleans.Streams

程序集:

Orleans.Streaming.dll

包:

Microsoft.Orleans.Streaming v8.2.0

此接口通用化 IAsyncObserver 接口，以允许生产批项。

请注意，此接口 (由项目生成者) 使用。

public interface IAsyncBatchProducer<T> : Orleans.Streams.IAsyncObserver<T>

type IAsyncBatchProducer<'T> = interface
    interface IAsyncObserver<'T>

Public Interface IAsyncBatchProducer(Of T)
Implements IAsyncObserver(Of T)

类型参数

T

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

派生

Orleans.Streams.IAsyncStream<T>

实现

IAsyncObserver<T>

方法

OnCompletedAsync()	通知使用者流已完成。 当使用者完成处理流关闭时，应完成从此方法返回的任务。 (继承自 IAsyncObserver<T>)
OnErrorAsync(Exception)	通知使用者流出错。 当使用者完成处理流关闭时，应完成从此方法返回的任务。 (继承自 IAsyncObserver<T>)
OnNextAsync(T, StreamSequenceToken)	将下一项传递给使用者。 当使用者已足够处理项目处理以满足任何行为保证时，应完成此方法返回的任务。 当使用者是流) 的 (生成方终结点时，当流实现已接受对项目负责并保证满足其交付保证时，任务将完成。 例如，基于持久队列的流会在项持久保存后完成任务。 一次传递时提供最大努力的流将返回已完成的任务。 当生成者是) 流的 (使用者终结点时，当任务接受项目责任时，应由使用者代码完成。 特别是，如果流提供程序保证至少传递一次，则在使用者返回的任务完成之前，不应将该项目视为已交付。 (继承自 IAsyncObserver<T>)
OnNextBatchAsync(IEnumerable<T>, StreamSequenceToken)	将下一批项目传递给使用者。 当使用者已足够处理批处理中的所有项以满足任何行为保证时，应完成此方法返回的任务。 也就是说，返回的任务的语义与 OnNextAsync(T, StreamSequenceToken)批处理中所有项的语义相同。