IAsyncBatchObservable<T>.SubscribeAsync 方法

定义

重载

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 的承诺。 使用者可以使用此句柄取消订阅。 只要订阅未显式取消订阅,订阅就保持活动状态。

适用于