次の方法で共有


IAsyncBatchObservable<T>.SubscribeAsync メソッド

定義

オーバーロード

SubscribeAsync(IAsyncBatchObserver<T>)

コンシューマーをこのバッチ監視可能にサブスクライブします。

SubscribeAsync(IAsyncBatchObserver<T>, StreamSequenceToken)

コンシューマーをこのバッチ監視可能にサブスクライブします。

SubscribeAsync(IAsyncBatchObserver<T>)

ソース:
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 の promise。 コンシューマーは、このハンドルを使用して登録を解除できます。 サブスクリプションが明示的にサブスクライブ解除されていない限り、サブスクリプションはアクティブなままです。

適用対象

SubscribeAsync(IAsyncBatchObserver<T>, StreamSequenceToken)

ソース:
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 の promise。 コンシューマーは、このハンドルを使用して登録を解除できます。 サブスクリプションが明示的にサブスクライブ解除されていない限り、サブスクリプションはアクティブなままです。

適用対象