IAsyncObservable<T>.SubscribeAsync メソッド
定義
重要
一部の情報は、リリース前に大きく変更される可能性があるプレリリースされた製品に関するものです。 Microsoft は、ここに記載されている情報について、明示または黙示を問わず、一切保証しません。
オーバーロード
| SubscribeAsync(IAsyncObserver<T>) |
コンシューマーをこの監視可能にサブスクライブします。 |
| SubscribeAsync(IAsyncObserver<T>, StreamSequenceToken, String) |
コンシューマーをこの監視可能にサブスクライブします。 |
| SubscribeAsync(IAsyncObserver<T>, StreamSequenceToken, StreamFilterPredicate, Object) |
コンシューマーをこの監視可能にサブスクライブします。 |
SubscribeAsync(IAsyncObserver<T>)
コンシューマーをこの監視可能にサブスクライブします。
public System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync (Orleans.Streams.IAsyncObserver<T> observer);abstract member SubscribeAsync : Orleans.Streams.IAsyncObserver<'T> -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>>Public Function SubscribeAsync (observer As IAsyncObserver(Of T)) As Task(Of StreamSubscriptionHandle(Of T))パラメーター
- observer
- IAsyncObserver<T>
サブスクライブする非同期オブザーバー。
戻り値
サブスクリプションを表す StreamSubscriptionHandle の promise。 コンシューマーは、このハンドルを使用してサブスクライブを解除できます。 サブスクリプションが明示的にサブスクライブ解除されていない限り、サブスクリプションはアクティブなままです。
適用対象
SubscribeAsync(IAsyncObserver<T>, StreamSequenceToken, String)
コンシューマーをこの監視可能にサブスクライブします。
public System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync (Orleans.Streams.IAsyncObserver<T> observer, Orleans.Streams.StreamSequenceToken? token, string? filterData = default);abstract member SubscribeAsync : Orleans.Streams.IAsyncObserver<'T> * Orleans.Streams.StreamSequenceToken * string -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>>Public Function SubscribeAsync (observer As IAsyncObserver(Of T), token As StreamSequenceToken, Optional filterData As String = Nothing) As Task(Of StreamSubscriptionHandle(Of T))パラメーター
- observer
- IAsyncObserver<T>
サブスクライブする非同期オブザーバー。
- token
- StreamSequenceToken
サブスクリプションを開始するオフセットとして使用されるストリーム シーケンス。
- filterData
- String
フィルターに渡されるデータ オブジェクト。
戻り値
サブスクリプションを表す StreamSubscriptionHandle の promise。 コンシューマーは、このハンドルを使用してサブスクライブを解除できます。 サブスクリプションが明示的にサブスクライブ解除されていない限り、サブスクリプションはアクティブなままです。
適用対象
SubscribeAsync(IAsyncObserver<T>, StreamSequenceToken, StreamFilterPredicate, Object)
コンシューマーをこの監視可能にサブスクライブします。
public System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync (Orleans.Streams.IAsyncObserver<T> observer, Orleans.Streams.StreamSequenceToken token, Orleans.Streams.StreamFilterPredicate filterFunc = default, object filterData = default);abstract member SubscribeAsync : Orleans.Streams.IAsyncObserver<'T> * Orleans.Streams.StreamSequenceToken * Orleans.Streams.StreamFilterPredicate * obj -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>>Public Function SubscribeAsync (observer As IAsyncObserver(Of T), token As StreamSequenceToken, Optional filterFunc As StreamFilterPredicate = Nothing, Optional filterData As Object = Nothing) As Task(Of StreamSubscriptionHandle(Of T))パラメーター
- observer
- IAsyncObserver<T>
サブスクライブする非同期オブザーバー。
- token
- StreamSequenceToken
サブスクリプションを開始するオフセットとして使用されるストリーム シーケンス。
- filterFunc
- StreamFilterPredicate
このサブスクリプションに適用するフィルター
- filterData
- Object
filterFunc に渡されるデータ オブジェクト。 これには通常、フィルター処理の決定を行うために filterFunc に必要なパラメーターが含まれます。
戻り値
サブスクリプションを表す StreamSubscriptionHandle の promise。 コンシューマーは、このハンドルを使用してサブスクライブを解除できます。 サブスクリプションが明示的にサブスクライブ解除されていない限り、サブスクリプションはアクティブなままになります。
例外
指定されたストリーム フィルター関数が適していない場合にスローされます。 通常、これは静的メソッドではないのでです。