IAsyncObservable<T> 接口

定义

命名空间:

Orleans.Streams

程序集:

Orleans.Streaming.dll

包:

Microsoft.Orleans.Streaming v8.2.0

此接口通用化标准 .NET IObserveable 接口，以允许异步使用项。 此处异步表示使用者可以异步处理项，并通过完成返回的任务向生成者发出项完成信号。

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

public interface IAsyncObservable<T>

type IAsyncObservable<'T> = interface

Public Interface IAsyncObservable(Of T)

类型参数

T

可观测对象生成的对象类型。

派生

Orleans.Streams.IAsyncStream<T>

方法

SubscribeAsync(IAsyncObserver<T>, StreamSequenceToken, String)	将使用者订阅到此可观测项。
SubscribeAsync(IAsyncObserver<T>)	将使用者订阅到此可观测项。

扩展方法

SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, StreamSequenceToken)	使用委托将使用者订阅到此可观测项。 此方法是 IAsyncObservable.SubscribeAsync 的帮助程序，允许订阅类内联处理程序方法，而无需 IAsyncObserver 实例。
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, StreamSequenceToken)	使用委托将使用者订阅到此可观测项。 此方法是 IAsyncObservable.SubscribeAsync 的帮助程序，允许订阅类内联处理程序方法，而无需 IAsyncObserver 实例。
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, Func<Task>, StreamSequenceToken)	使用委托将使用者订阅到此可观测项。 此方法是 IAsyncObservable.SubscribeAsync 的帮助程序，允许订阅类内联处理程序方法，而无需 IAsyncObserver 实例。
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, Func<Task>)	使用委托将使用者订阅到此可观测项。 此方法是 IAsyncObservable.SubscribeAsync 的帮助程序，允许订阅类内联处理程序方法，而无需 IAsyncObserver 实例。
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>)	使用委托将使用者订阅到此可观测项。 此方法是 IAsyncObservable.SubscribeAsync 的帮助程序，允许订阅类内联处理程序方法，而无需 IAsyncObserver 实例。
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Task>, StreamSequenceToken)	使用委托将使用者订阅到此可观测项。 此方法是 IAsyncObservable.SubscribeAsync 的帮助程序，允许订阅类内联处理程序方法，而无需 IAsyncObserver 实例。
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Task>)	使用委托将使用者订阅到此可观测项。 此方法是 IAsyncObservable.SubscribeAsync 的帮助程序，允许订阅类内联处理程序方法，而无需 IAsyncObserver 实例。
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>)	使用委托将使用者订阅到此可观测项。 此方法是 IAsyncObservable.SubscribeAsync 的帮助程序，允许订阅类内联处理程序方法，而无需 IAsyncObserver 实例。