IAsyncBatchObservable<T>.SubscribeAsync 方法
定义
重要
一些信息与预发行产品相关,相应产品在发行之前可能会进行重大修改。 对于此处提供的信息,Microsoft 不作任何明示或暗示的担保。
重载
SubscribeAsync(IAsyncBatchObserver<T>) |
订阅使用者可观察此批。 |
SubscribeAsync(IAsyncBatchObserver<T>, StreamSequenceToken) |
订阅使用者可观察此批。 |
SubscribeAsync(IAsyncBatchObserver<T>)
- Source:
- IAsyncBatchObservable.cs
订阅使用者可观察此批。
public System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync (Orleans.Streams.IAsyncBatchObserver<T> observer);
abstract member SubscribeAsync : Orleans.Streams.IAsyncBatchObserver<'T> -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>>
Public Function SubscribeAsync (observer As IAsyncBatchObserver(Of T)) As Task(Of StreamSubscriptionHandle(Of T))
参数
- observer
- IAsyncBatchObserver<T>
要订阅的异步批处理观察程序。
返回
表示订阅的 StreamSubscriptionHandle 的承诺。 使用者可以使用此句柄取消订阅。 只要订阅未显式取消订阅,订阅就保持活动状态。
适用于
SubscribeAsync(IAsyncBatchObserver<T>, StreamSequenceToken)
- Source:
- IAsyncBatchObservable.cs
订阅使用者可观察此批。
public System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync (Orleans.Streams.IAsyncBatchObserver<T> observer, Orleans.Streams.StreamSequenceToken token);
public System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync (Orleans.Streams.IAsyncBatchObserver<T> observer, Orleans.Streams.StreamSequenceToken? token);
abstract member SubscribeAsync : Orleans.Streams.IAsyncBatchObserver<'T> * Orleans.Streams.StreamSequenceToken -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>>
Public Function SubscribeAsync (observer As IAsyncBatchObserver(Of T), token As StreamSequenceToken) As Task(Of StreamSubscriptionHandle(Of T))
参数
- observer
- IAsyncBatchObserver<T>
要订阅的异步批处理观察程序。
- token
- StreamSequenceToken
要用作从中启动订阅的偏移量的流序列。
返回
表示订阅的 StreamSubscriptionHandle 的承诺。 使用者可以使用此句柄取消订阅。 只要订阅未显式取消订阅,订阅就保持活动状态。