IAsyncBatchObservable<T> 接口

定义

命名空间:

Orleans.Streams

程序集:

Orleans.Streaming.dll

包:

Microsoft.Orleans.Streaming v8.2.0

此接口通用化 IAsyncObserver 接口，以允许对批项进行生产和消耗。

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

public interface IAsyncBatchObservable<T>

type IAsyncBatchObservable<'T> = interface

Public Interface IAsyncBatchObservable(Of T)

类型参数

T

观察程序使用的对象的类型。

派生

Orleans.Streams.IAsyncStream<T>

方法

SubscribeAsync(IAsyncBatchObserver<T>)	订阅使用者可观察此批。
SubscribeAsync(IAsyncBatchObserver<T>, StreamSequenceToken)	订阅使用者可观察此批。

扩展方法

SubscribeAsync<T>(IAsyncBatchObservable<T>, Func<IList<SequentialItem<T>>,Task>)	使用委托向使用者订阅此可观察的使用者。 此方法是 IAsyncBatchObservable.SubscribeAsync 的帮助程序，允许订阅类内联处理程序方法，而无需 IAsyncBatchObserver 实例。
SubscribeAsync<T>(IAsyncBatchObservable<T>, Func<IList<SequentialItem<T>>,Task>, Func<Exception,Task>)	使用委托向使用者订阅此可观察的使用者。 此方法是 IAsyncBatchObservable.SubscribeAsync 的帮助程序，允许订阅类内联处理程序方法，而无需 IAsyncBatchObserver 实例。
SubscribeAsync<T>(IAsyncBatchObservable<T>, Func<IList<SequentialItem<T>>,Task>, Func<Exception,Task>, Func<Task>)	使用委托向使用者订阅此可观察的使用者。 此方法是 IAsyncBatchObservable.SubscribeAsync 的帮助程序，允许订阅类内联处理程序方法，而无需 IAsyncBatchObserver 实例。
SubscribeAsync<T>(IAsyncBatchObservable<T>, Func<IList<SequentialItem<T>>,Task>, Func<Task>)	使用委托向使用者订阅此可观察的使用者。 此方法是 IAsyncBatchObservable.SubscribeAsync 的帮助程序，允许订阅类内联处理程序方法，而无需 IAsyncBatchObserver 实例。