AsyncObservableExtensions 类

定义

命名空间:

Orleans.Streams

程序集:

Orleans.Streaming.dll

包:

Microsoft.Orleans.Streaming v8.2.0

IAsyncObservable<T> 的扩展方法。

public static class AsyncObservableExtensions

type AsyncObservableExtensions = class

Public Module AsyncObservableExtensions

继承

Object

AsyncObservableExtensions

方法

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