AsyncBatchObservableExtensions.SubscribeAsync 方法
定义
重要
一些信息与预发行产品相关，相应产品在发行之前可能会进行重大修改。 对于此处提供的信息，Microsoft 不作任何明示或暗示的担保。
重载
| 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<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>)
使用委托将使用者订阅到此可观察的。 此方法是 IAsyncBatchObservable.SubscribeAsync 的帮助程序，允许订阅类内联处理程序方法，而无需 IAsyncBatchObserver 实例。
public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T> (this Orleans.Streams.IAsyncBatchObservable<T> obs, Func<System.Collections.Generic.IList<Orleans.Streams.SequentialItem<T>>,System.Threading.Tasks.Task> onNextAsync);static member SubscribeAsync : Orleans.Streams.IAsyncBatchObservable<'T> * Func<System.Collections.Generic.IList<Orleans.Streams.SequentialItem<'T>>, System.Threading.Tasks.Task> -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>><Extension()>
Public Function SubscribeAsync(Of T) (obs As IAsyncBatchObservable(Of T), onNextAsync As Func(Of IList(Of SequentialItem(Of T)), Task)) As Task(Of StreamSubscriptionHandle(Of T))类型参数
- T
可观测对象生成的对象类型。
参数
可观测对象。
- onNextAsync
- Func<IList<SequentialItem<T>>,Task>
为 IAsyncBatchObserver.OnNextAsync 调用的委托。
返回
表示订阅的 StreamSubscriptionHandle 的承诺。 使用者可以使用此句柄取消订阅。 只要订阅未显式取消订阅，订阅就保持活动状态。
适用于
SubscribeAsync<T>(IAsyncBatchObservable<T>, Func<IList<SequentialItem<T>>,Task>, Func<Exception,Task>)
使用委托将使用者订阅到此可观察的。 此方法是 IAsyncBatchObservable.SubscribeAsync 的帮助程序，允许订阅类内联处理程序方法，而无需 IAsyncBatchObserver 实例。
public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T> (this Orleans.Streams.IAsyncBatchObservable<T> obs, Func<System.Collections.Generic.IList<Orleans.Streams.SequentialItem<T>>,System.Threading.Tasks.Task> onNextAsync, Func<Exception,System.Threading.Tasks.Task> onErrorAsync);static member SubscribeAsync : Orleans.Streams.IAsyncBatchObservable<'T> * Func<System.Collections.Generic.IList<Orleans.Streams.SequentialItem<'T>>, System.Threading.Tasks.Task> * Func<Exception, System.Threading.Tasks.Task> -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>><Extension()>
Public Function SubscribeAsync(Of T) (obs As IAsyncBatchObservable(Of T), onNextAsync As Func(Of IList(Of SequentialItem(Of T)), Task), onErrorAsync As Func(Of Exception, Task)) As Task(Of StreamSubscriptionHandle(Of T))类型参数
- T
可观测对象生成的对象类型。
参数
可观测对象。
- onNextAsync
- Func<IList<SequentialItem<T>>,Task>
为 IAsyncBatchObserver.OnNextAsync 调用的委托。
返回
表示订阅的 StreamSubscriptionHandle 的承诺。 使用者可以使用此句柄取消订阅。 只要订阅未显式取消订阅，订阅就保持活动状态。
适用于
SubscribeAsync<T>(IAsyncBatchObservable<T>, Func<IList<SequentialItem<T>>,Task>, Func<Task>)
使用委托将使用者订阅到此可观察的。 此方法是 IAsyncBatchObservable.SubscribeAsync 的帮助程序，允许订阅类内联处理程序方法，而无需 IAsyncBatchObserver 实例。
public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T> (this Orleans.Streams.IAsyncBatchObservable<T> obs, Func<System.Collections.Generic.IList<Orleans.Streams.SequentialItem<T>>,System.Threading.Tasks.Task> onNextAsync, Func<System.Threading.Tasks.Task> onCompletedAsync);static member SubscribeAsync : Orleans.Streams.IAsyncBatchObservable<'T> * Func<System.Collections.Generic.IList<Orleans.Streams.SequentialItem<'T>>, System.Threading.Tasks.Task> * Func<System.Threading.Tasks.Task> -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>><Extension()>
Public Function SubscribeAsync(Of T) (obs As IAsyncBatchObservable(Of T), onNextAsync As Func(Of IList(Of SequentialItem(Of T)), Task), onCompletedAsync As Func(Of Task)) As Task(Of StreamSubscriptionHandle(Of T))类型参数
- T
可观测对象生成的对象类型。
参数
可观测对象。
- onNextAsync
- Func<IList<SequentialItem<T>>,Task>
为 IAsyncBatchObserver.OnNextAsync 调用的委托。
返回
表示订阅的 StreamSubscriptionHandle 的承诺。 使用者可以使用此句柄取消订阅。 只要订阅未显式取消订阅，订阅就保持活动状态。
适用于
SubscribeAsync<T>(IAsyncBatchObservable<T>, Func<IList<SequentialItem<T>>,Task>, Func<Exception,Task>, Func<Task>)
使用委托将使用者订阅到此可观察的。 此方法是 IAsyncBatchObservable.SubscribeAsync 的帮助程序，允许订阅类内联处理程序方法，而无需 IAsyncBatchObserver 实例。
public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T> (this Orleans.Streams.IAsyncBatchObservable<T> obs, Func<System.Collections.Generic.IList<Orleans.Streams.SequentialItem<T>>,System.Threading.Tasks.Task> onNextAsync, Func<Exception,System.Threading.Tasks.Task> onErrorAsync, Func<System.Threading.Tasks.Task> onCompletedAsync);static member SubscribeAsync : Orleans.Streams.IAsyncBatchObservable<'T> * Func<System.Collections.Generic.IList<Orleans.Streams.SequentialItem<'T>>, System.Threading.Tasks.Task> * Func<Exception, System.Threading.Tasks.Task> * Func<System.Threading.Tasks.Task> -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>><Extension()>
Public Function SubscribeAsync(Of T) (obs As IAsyncBatchObservable(Of T), onNextAsync As Func(Of IList(Of SequentialItem(Of T)), Task), onErrorAsync As Func(Of Exception, Task), onCompletedAsync As Func(Of Task)) As Task(Of StreamSubscriptionHandle(Of T))类型参数
- T
可观测对象生成的对象类型。
参数
可观测对象。
- onNextAsync
- Func<IList<SequentialItem<T>>,Task>
为 IAsyncBatchObserver.OnNextAsync 调用的委托。
返回
表示订阅的 StreamSubscriptionHandle 的承诺。 使用者可以使用此句柄取消订阅。 只要订阅未显式取消订阅，订阅就保持活动状态。