AsyncObservableExtensions.SubscribeAsync メソッド
重要
一部の情報は、リリース前に大きく変更される可能性があるプレリリースされた製品に関するものです。 Microsoft は、ここに記載されている情報について、明示または黙示を問わず、一切保証しません。
| SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>) |
デリゲートを使用して、コンシューマーをこの監視可能にサブスクライブします。 このメソッドは IAsyncObservable.SubscribeAsync のヘルパーであり、サブスクライブ クラスは IAsyncObserver のインスタンスを必要とするのではなく、ハンドラー メソッドをインライン化できます。 |
| SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, StreamSequenceToken) |
デリゲートを使用して、コンシューマーをこの監視可能にサブスクライブします。 このメソッドは IAsyncObservable.SubscribeAsync のヘルパーであり、サブスクライブ クラスは IAsyncObserver のインスタンスを必要とするのではなく、ハンドラー メソッドをインライン化できます。 |
| SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>) |
デリゲートを使用して、コンシューマーをこの監視可能にサブスクライブします。 このメソッドは IAsyncObservable.SubscribeAsync のヘルパーであり、サブスクライブ クラスは IAsyncObserver のインスタンスを必要とするのではなく、ハンドラー メソッドをインライン化できます。 |
| SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Task>) |
デリゲートを使用して、コンシューマーをこの監視可能にサブスクライブします。 このメソッドは IAsyncObservable.SubscribeAsync のヘルパーであり、サブスクライブ クラスは IAsyncObserver のインスタンスを必要とするのではなく、ハンドラー メソッドをインライン化できます。 |
| SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, StreamSequenceToken) |
デリゲートを使用して、コンシューマーをこの監視可能にサブスクライブします。 このメソッドは IAsyncObservable.SubscribeAsync のヘルパーであり、サブスクライブ クラスは IAsyncObserver のインスタンスを必要とするのではなく、ハンドラー メソッドをインライン化できます。 |
| SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, Func<Task>) |
デリゲートを使用して、コンシューマーをこの監視可能にサブスクライブします。 このメソッドは IAsyncObservable.SubscribeAsync のヘルパーであり、サブスクライブ クラスは IAsyncObserver のインスタンスを必要とするのではなく、ハンドラー メソッドをインライン化できます。 |
| SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Task>, StreamSequenceToken) |
デリゲートを使用して、コンシューマーをこの監視可能にサブスクライブします。 このメソッドは IAsyncObservable.SubscribeAsync のヘルパーであり、サブスクライブ クラスは IAsyncObserver のインスタンスを必要とするのではなく、ハンドラー メソッドをインライン化できます。 |
| SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, StreamSequenceToken, StreamFilterPredicate, Object) |
デリゲートを使用して、コンシューマーをこの監視可能にサブスクライブします。 このメソッドは IAsyncObservable.SubscribeAsync のヘルパーであり、サブスクライブ クラスは IAsyncObserver のインスタンスを必要とするのではなく、ハンドラー メソッドをインライン化できます。 |
| SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, Func<Task>, StreamSequenceToken) |
デリゲートを使用して、コンシューマーをこの監視可能にサブスクライブします。 このメソッドは IAsyncObservable.SubscribeAsync のヘルパーであり、サブスクライブ クラスは IAsyncObserver のインスタンスを必要とするのではなく、ハンドラー メソッドをインライン化できます。 |
| SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, StreamSequenceToken, StreamFilterPredicate, Object) |
デリゲートを使用して、コンシューマーをこの監視可能にサブスクライブします。 このメソッドは IAsyncObservable.SubscribeAsync のヘルパーであり、サブスクライブ クラスは IAsyncObserver のインスタンスを必要とするのではなく、ハンドラー メソッドをインライン化できます。 |
| SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Task>, StreamSequenceToken, StreamFilterPredicate, Object) |
デリゲートを使用して、コンシューマーをこの監視可能にサブスクライブします。 このメソッドは IAsyncObservable.SubscribeAsync のヘルパーであり、サブスクライブ クラスは IAsyncObserver のインスタンスを必要とするのではなく、ハンドラー メソッドをインライン化できます。 |
| SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken, Task>, Func<Exception,Task>, Func<Task>, StreamSequenceToken, StreamFilterPredicate, Object) |
デリゲートを使用して、コンシューマーをこの監視可能にサブスクライブします。 このメソッドは IAsyncObservable.SubscribeAsync のヘルパーであり、サブスクライブ クラスは IAsyncObserver のインスタンスを必要とするのではなく、ハンドラー メソッドをインライン化できます。 |
デリゲートを使用して、コンシューマーをこの監視可能にサブスクライブします。 このメソッドは IAsyncObservable.SubscribeAsync のヘルパーであり、サブスクライブ クラスは IAsyncObserver のインスタンスを必要とするのではなく、ハンドラー メソッドをインライン化できます。
public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T>(this Orleans.Streams.IAsyncObservable<T> obs, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync);static member SubscribeAsync : Orleans.Streams.IAsyncObservable<'T> * Func<'T, Orleans.Streams.StreamSequenceToken, System.Threading.Tasks.Task> -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>><Extension()>
Public Function SubscribeAsync(Of T) (obs As IAsyncObservable(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task)) As Task(Of StreamSubscriptionHandle(Of T))型パラメーター
- T
監視可能オブジェクトによって生成されるオブジェクトの型。
パラメーター
Observable オブジェクト。
- onNextAsync
- Func<T,StreamSequenceToken,Task>
IAsyncObserver.OnNextAsync に対して呼び出されるデリゲート。
戻り値
サブスクリプションを表す StreamSubscriptionHandle の promise。 コンシューマーは、このハンドルを使用して登録を解除できます。 サブスクリプションが明示的にサブスクライブ解除されていない限り、サブスクリプションはアクティブなままです。
適用対象
デリゲートを使用して、コンシューマーをこの監視可能にサブスクライブします。 このメソッドは IAsyncObservable.SubscribeAsync のヘルパーであり、サブスクライブ クラスは IAsyncObserver のインスタンスを必要とするのではなく、ハンドラー メソッドをインライン化できます。
public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T>(this Orleans.Streams.IAsyncObservable<T> obs, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync, Orleans.Streams.StreamSequenceToken token);static member SubscribeAsync : Orleans.Streams.IAsyncObservable<'T> * Func<'T, Orleans.Streams.StreamSequenceToken, System.Threading.Tasks.Task> * Orleans.Streams.StreamSequenceToken -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>><Extension()>
Public Function SubscribeAsync(Of T) (obs As IAsyncObservable(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task), token As StreamSequenceToken) As Task(Of StreamSubscriptionHandle(Of T))型パラメーター
- T
監視可能オブジェクトによって生成されるオブジェクトの型。
パラメーター
Observable オブジェクト。
- onNextAsync
- Func<T,StreamSequenceToken,Task>
IAsyncObserver.OnNextAsync に対して呼び出されるデリゲート。
- token
- StreamSequenceToken
サブスクリプションの開始元のオフセットとして使用されるストリーム シーケンス。
戻り値
サブスクリプションを表す StreamSubscriptionHandle の promise。 コンシューマーは、このハンドルを使用して登録を解除できます。 サブスクリプションが明示的にサブスクライブ解除されていない限り、サブスクリプションはアクティブなままです。
例外
指定されたストリーム フィルター関数が適切でない場合にスローされます。 通常、これは静的メソッドではないのでです。
適用対象
デリゲートを使用して、コンシューマーをこの監視可能にサブスクライブします。 このメソッドは IAsyncObservable.SubscribeAsync のヘルパーであり、サブスクライブ クラスは IAsyncObserver のインスタンスを必要とするのではなく、ハンドラー メソッドをインライン化できます。
public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T>(this Orleans.Streams.IAsyncObservable<T> obs, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync, Func<Exception,System.Threading.Tasks.Task> onErrorAsync);static member SubscribeAsync : Orleans.Streams.IAsyncObservable<'T> * Func<'T, Orleans.Streams.StreamSequenceToken, 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 IAsyncObservable(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task), onErrorAsync As Func(Of Exception, Task)) As Task(Of StreamSubscriptionHandle(Of T))型パラメーター
- T
監視可能オブジェクトによって生成されるオブジェクトの型。
パラメーター
Observable オブジェクト。
- onNextAsync
- Func<T,StreamSequenceToken,Task>
IAsyncObserver.OnNextAsync に対して呼び出されるデリゲート。
戻り値
サブスクリプションを表す StreamSubscriptionHandle の promise。 コンシューマーは、このハンドルを使用して登録を解除できます。 サブスクリプションが明示的にサブスクライブ解除されていない限り、サブスクリプションはアクティブなままです。
適用対象
デリゲートを使用して、コンシューマーをこの監視可能にサブスクライブします。 このメソッドは IAsyncObservable.SubscribeAsync のヘルパーであり、サブスクライブ クラスは IAsyncObserver のインスタンスを必要とするのではなく、ハンドラー メソッドをインライン化できます。
public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T>(this Orleans.Streams.IAsyncObservable<T> obs, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync, Func<System.Threading.Tasks.Task> onCompletedAsync);static member SubscribeAsync : Orleans.Streams.IAsyncObservable<'T> * Func<'T, Orleans.Streams.StreamSequenceToken, 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 IAsyncObservable(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task), onCompletedAsync As Func(Of Task)) As Task(Of StreamSubscriptionHandle(Of T))型パラメーター
- T
監視可能オブジェクトによって生成されるオブジェクトの型。
パラメーター
Observable オブジェクト。
- onNextAsync
- Func<T,StreamSequenceToken,Task>
IAsyncObserver.OnNextAsync に対して呼び出されるデリゲート。
戻り値
サブスクリプションを表す StreamSubscriptionHandle の promise。 コンシューマーは、このハンドルを使用して登録を解除できます。 サブスクリプションが明示的にサブスクライブ解除されていない限り、サブスクリプションはアクティブなままです。
適用対象
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, StreamSequenceToken)
デリゲートを使用して、コンシューマーをこの監視可能にサブスクライブします。 このメソッドは IAsyncObservable.SubscribeAsync のヘルパーであり、サブスクライブ クラスは IAsyncObserver のインスタンスを必要とするのではなく、ハンドラー メソッドをインライン化できます。
public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T>(this Orleans.Streams.IAsyncObservable<T> obs, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync, Func<Exception,System.Threading.Tasks.Task> onErrorAsync, Orleans.Streams.StreamSequenceToken token);static member SubscribeAsync : Orleans.Streams.IAsyncObservable<'T> * Func<'T, Orleans.Streams.StreamSequenceToken, System.Threading.Tasks.Task> * Func<Exception, System.Threading.Tasks.Task> * Orleans.Streams.StreamSequenceToken -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>><Extension()>
Public Function SubscribeAsync(Of T) (obs As IAsyncObservable(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task), onErrorAsync As Func(Of Exception, Task), token As StreamSequenceToken) As Task(Of StreamSubscriptionHandle(Of T))型パラメーター
- T
監視可能オブジェクトによって生成されるオブジェクトの型。
パラメーター
Observable オブジェクト。
- onNextAsync
- Func<T,StreamSequenceToken,Task>
IAsyncObserver.OnNextAsync に対して呼び出されるデリゲート。
- token
- StreamSequenceToken
サブスクリプションの開始元のオフセットとして使用されるストリーム シーケンス。
戻り値
サブスクリプションを表す StreamSubscriptionHandle の promise。 コンシューマーは、このハンドルを使用して登録を解除できます。 サブスクリプションが明示的にサブスクライブ解除されていない限り、サブスクリプションはアクティブなままです。
例外
指定されたストリーム フィルター関数が適切でない場合にスローされます。 通常、これは静的メソッドではないのでです。
適用対象
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, Func<Task>)
デリゲートを使用して、コンシューマーをこの監視可能にサブスクライブします。 このメソッドは IAsyncObservable.SubscribeAsync のヘルパーであり、サブスクライブ クラスは IAsyncObserver のインスタンスを必要とするのではなく、ハンドラー メソッドをインライン化できます。
public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T>(this Orleans.Streams.IAsyncObservable<T> obs, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync, Func<Exception,System.Threading.Tasks.Task> onErrorAsync, Func<System.Threading.Tasks.Task> onCompletedAsync);static member SubscribeAsync : Orleans.Streams.IAsyncObservable<'T> * Func<'T, Orleans.Streams.StreamSequenceToken, 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 IAsyncObservable(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task), onErrorAsync As Func(Of Exception, Task), onCompletedAsync As Func(Of Task)) As Task(Of StreamSubscriptionHandle(Of T))型パラメーター
- T
observable によって生成されるオブジェクトの型。
パラメーター
Observable オブジェクト。
- onNextAsync
- Func<T,StreamSequenceToken,Task>
IAsyncObserver.OnNextAsync に対して呼び出されるデリゲート。
戻り値
サブスクリプションを表す StreamSubscriptionHandle の promise。 コンシューマーは、このハンドルを使用してサブスクライブを解除できます。 サブスクリプションが明示的にサブスクライブ解除されていない限り、サブスクリプションはアクティブなままです。
適用対象
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Task>, StreamSequenceToken)
デリゲートを使用して、コンシューマーをこの監視可能にサブスクライブします。 このメソッドは IAsyncObservable.SubscribeAsync のヘルパーであり、サブスクライブ クラスは IAsyncObserver のインスタンスを必要とするのではなく、ハンドラー メソッドをインライン化できます。
public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T>(this Orleans.Streams.IAsyncObservable<T> obs, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync, Func<System.Threading.Tasks.Task> onCompletedAsync, Orleans.Streams.StreamSequenceToken token);static member SubscribeAsync : Orleans.Streams.IAsyncObservable<'T> * Func<'T, Orleans.Streams.StreamSequenceToken, System.Threading.Tasks.Task> * Func<System.Threading.Tasks.Task> * Orleans.Streams.StreamSequenceToken -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>><Extension()>
Public Function SubscribeAsync(Of T) (obs As IAsyncObservable(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task), onCompletedAsync As Func(Of Task), token As StreamSequenceToken) As Task(Of StreamSubscriptionHandle(Of T))型パラメーター
- T
observable によって生成されるオブジェクトの型。
パラメーター
Observable オブジェクト。
- onNextAsync
- Func<T,StreamSequenceToken,Task>
IAsyncObserver.OnNextAsync に対して呼び出されるデリゲート。
- token
- StreamSequenceToken
サブスクリプションを開始するオフセットとして使用されるストリーム シーケンス。
戻り値
サブスクリプションを表す StreamSubscriptionHandle の promise。 コンシューマーは、このハンドルを使用してサブスクライブを解除できます。 サブスクリプションが明示的にサブスクライブ解除されていない限り、サブスクリプションはアクティブなままです。
例外
指定されたストリーム フィルター関数が適していない場合にスローされます。 通常、これは静的メソッドではないのでです。
適用対象
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, StreamSequenceToken, StreamFilterPredicate, Object)
デリゲートを使用して、コンシューマーをこの監視可能にサブスクライブします。 このメソッドは IAsyncObservable.SubscribeAsync のヘルパーであり、サブスクライブ クラスは IAsyncObserver のインスタンスを必要とするのではなく、ハンドラー メソッドをインライン化できます。
public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T>(this Orleans.Streams.IAsyncObservable<T> obs, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync, Orleans.Streams.StreamSequenceToken token, Orleans.Streams.StreamFilterPredicate filterFunc = default, object filterData = default);static member SubscribeAsync : Orleans.Streams.IAsyncObservable<'T> * Func<'T, Orleans.Streams.StreamSequenceToken, System.Threading.Tasks.Task> * Orleans.Streams.StreamSequenceToken * Orleans.Streams.StreamFilterPredicate * obj -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>><Extension()>
Public Function SubscribeAsync(Of T) (obs As IAsyncObservable(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task), token As StreamSequenceToken, Optional filterFunc As StreamFilterPredicate = Nothing, Optional filterData As Object = Nothing) As Task(Of StreamSubscriptionHandle(Of T))型パラメーター
- T
observable によって生成されるオブジェクトの型。
パラメーター
Observable オブジェクト。
- onNextAsync
- Func<T,StreamSequenceToken,Task>
IAsyncObserver.OnNextAsync に対して呼び出される Delegte。
- token
- StreamSequenceToken
サブスクリプションを開始するオフセットとして使用されるストリーム シーケンス。
- filterFunc
- StreamFilterPredicate
このサブスクリプションに適用するフィルター
- filterData
- Object
filterFunc に渡されるデータ オブジェクト。 これには通常、フィルター処理の決定を行うために filterFunc に必要なパラメーターが含まれます。
戻り値
サブスクリプションを表す StreamSubscriptionHandle の promise。 コンシューマーは、このハンドルを使用してサブスクライブを解除できます。 サブスクリプションが明示的にサブスクライブ解除されていない限り、サブスクリプションはアクティブなままになります。
例外
指定されたストリーム フィルター関数が適していない場合にスローされます。 通常、これは静的メソッドではないのでです。
適用対象
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, Func<Task>, StreamSequenceToken)
デリゲートを使用して、コンシューマーをこの監視可能にサブスクライブします。 このメソッドは IAsyncObservable.SubscribeAsync のヘルパーであり、サブスクライブ クラスは IAsyncObserver のインスタンスを必要とするのではなく、ハンドラー メソッドをインライン化できます。
public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T>(this Orleans.Streams.IAsyncObservable<T> obs, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync, Func<Exception,System.Threading.Tasks.Task> onErrorAsync, Func<System.Threading.Tasks.Task> onCompletedAsync, Orleans.Streams.StreamSequenceToken token);static member SubscribeAsync : Orleans.Streams.IAsyncObservable<'T> * Func<'T, Orleans.Streams.StreamSequenceToken, System.Threading.Tasks.Task> * Func<Exception, System.Threading.Tasks.Task> * Func<System.Threading.Tasks.Task> * Orleans.Streams.StreamSequenceToken -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>><Extension()>
Public Function SubscribeAsync(Of T) (obs As IAsyncObservable(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task), onErrorAsync As Func(Of Exception, Task), onCompletedAsync As Func(Of Task), token As StreamSequenceToken) As Task(Of StreamSubscriptionHandle(Of T))型パラメーター
- T
observable によって生成されるオブジェクトの型。
パラメーター
Observable オブジェクト。
- onNextAsync
- Func<T,StreamSequenceToken,Task>
IAsyncObserver.OnNextAsync に対して呼び出されるデリゲート。
- token
- StreamSequenceToken
サブスクリプションを開始するオフセットとして使用されるストリーム シーケンス。
戻り値
サブスクリプションを表す StreamSubscriptionHandle の promise。 コンシューマーは、このハンドルを使用してサブスクライブを解除できます。 サブスクリプションが明示的にサブスクライブ解除されていない限り、サブスクリプションはアクティブなままです。
例外
指定されたストリーム フィルター関数が適していない場合にスローされます。 通常、これは静的メソッドではないのでです。
適用対象
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, StreamSequenceToken, StreamFilterPredicate, Object)
デリゲートを使用して、コンシューマーをこの監視可能にサブスクライブします。 このメソッドは IAsyncObservable.SubscribeAsync のヘルパーであり、サブスクライブ クラスは IAsyncObserver のインスタンスを必要とするのではなく、ハンドラー メソッドをインライン化できます。
public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T>(this Orleans.Streams.IAsyncObservable<T> obs, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync, Func<Exception,System.Threading.Tasks.Task> onErrorAsync, Orleans.Streams.StreamSequenceToken token, Orleans.Streams.StreamFilterPredicate filterFunc = default, object filterData = default);static member SubscribeAsync : Orleans.Streams.IAsyncObservable<'T> * Func<'T, Orleans.Streams.StreamSequenceToken, System.Threading.Tasks.Task> * Func<Exception, System.Threading.Tasks.Task> * Orleans.Streams.StreamSequenceToken * Orleans.Streams.StreamFilterPredicate * obj -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>><Extension()>
Public Function SubscribeAsync(Of T) (obs As IAsyncObservable(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task), onErrorAsync As Func(Of Exception, Task), token As StreamSequenceToken, Optional filterFunc As StreamFilterPredicate = Nothing, Optional filterData As Object = Nothing) As Task(Of StreamSubscriptionHandle(Of T))型パラメーター
- T
observable によって生成されるオブジェクトの型。
パラメーター
Observable オブジェクト。
- onNextAsync
- Func<T,StreamSequenceToken,Task>
IAsyncObserver.OnNextAsync に対して呼び出される Delegte。
- token
- StreamSequenceToken
サブスクリプションを開始するオフセットとして使用されるストリーム シーケンス。
- filterFunc
- StreamFilterPredicate
このサブスクリプションに適用するフィルター
- filterData
- Object
filterFunc に渡されるデータ オブジェクト。 これには通常、フィルター処理の決定を行うために filterFunc に必要なパラメーターが含まれます。
戻り値
サブスクリプションを表す StreamSubscriptionHandle の promise。 コンシューマーは、このハンドルを使用してサブスクライブを解除できます。 サブスクリプションが明示的にサブスクライブ解除されていない限り、サブスクリプションはアクティブなままになります。
例外
指定されたストリーム フィルター関数が適していない場合にスローされます。 通常、これは静的メソッドではないのでです。
適用対象
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Task>, StreamSequenceToken, StreamFilterPredicate, Object)
デリゲートを使用して、コンシューマーをこの監視可能にサブスクライブします。 このメソッドは IAsyncObservable.SubscribeAsync のヘルパーであり、サブスクライブ クラスは IAsyncObserver のインスタンスを必要とするのではなく、ハンドラー メソッドをインライン化できます。
public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T>(this Orleans.Streams.IAsyncObservable<T> obs, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync, Func<System.Threading.Tasks.Task> onCompletedAsync, Orleans.Streams.StreamSequenceToken token, Orleans.Streams.StreamFilterPredicate filterFunc = default, object filterData = default);static member SubscribeAsync : Orleans.Streams.IAsyncObservable<'T> * Func<'T, Orleans.Streams.StreamSequenceToken, System.Threading.Tasks.Task> * Func<System.Threading.Tasks.Task> * Orleans.Streams.StreamSequenceToken * Orleans.Streams.StreamFilterPredicate * obj -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>><Extension()>
Public Function SubscribeAsync(Of T) (obs As IAsyncObservable(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task), onCompletedAsync As Func(Of Task), token As StreamSequenceToken, Optional filterFunc As StreamFilterPredicate = Nothing, Optional filterData As Object = Nothing) As Task(Of StreamSubscriptionHandle(Of T))型パラメーター
- T
observable によって生成されるオブジェクトの型。
パラメーター
Observable オブジェクト。
- onNextAsync
- Func<T,StreamSequenceToken,Task>
IAsyncObserver.OnNextAsync に対して呼び出される Delegte。
- token
- StreamSequenceToken
サブスクリプションを開始するオフセットとして使用されるストリーム シーケンス。
- filterFunc
- StreamFilterPredicate
このサブスクリプションに適用するフィルター
- filterData
- Object
filterFunc に渡されるデータ オブジェクト。 これには通常、フィルター処理の決定を行うために filterFunc に必要なパラメーターが含まれます。
戻り値
サブスクリプションを表す StreamSubscriptionHandle の promise。 コンシューマーは、このハンドルを使用してサブスクライブを解除できます。 サブスクリプションが明示的にサブスクライブ解除されていない限り、サブスクリプションはアクティブなままになります。
例外
指定されたストリーム フィルター関数が適していない場合にスローされます。 通常、これは静的メソッドではないのでです。
適用対象
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken, Task>, Func<Exception,Task>, Func<Task>, StreamSequenceToken, StreamFilterPredicate, Object)
デリゲートを使用して、コンシューマーをこの監視可能にサブスクライブします。 このメソッドは IAsyncObservable.SubscribeAsync のヘルパーであり、サブスクライブ クラスは IAsyncObserver のインスタンスを必要とするのではなく、ハンドラー メソッドをインライン化できます。
public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T>(this Orleans.Streams.IAsyncObservable<T> obs, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync, Func<Exception,System.Threading.Tasks.Task> onErrorAsync, Func<System.Threading.Tasks.Task> onCompletedAsync, Orleans.Streams.StreamSequenceToken token, Orleans.Streams.StreamFilterPredicate filterFunc = default, object filterData = default);static member SubscribeAsync : Orleans.Streams.IAsyncObservable<'T> * Func<'T, Orleans.Streams.StreamSequenceToken, System.Threading.Tasks.Task> * Func<Exception, System.Threading.Tasks.Task> * Func<System.Threading.Tasks.Task> * Orleans.Streams.StreamSequenceToken * Orleans.Streams.StreamFilterPredicate * obj -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>><Extension()>
Public Function SubscribeAsync(Of T) (obs As IAsyncObservable(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task), onErrorAsync As Func(Of Exception, Task), onCompletedAsync As Func(Of Task), token As StreamSequenceToken, Optional filterFunc As StreamFilterPredicate = Nothing, Optional filterData As Object = Nothing) As Task(Of StreamSubscriptionHandle(Of T))型パラメーター
- T
observable によって生成されるオブジェクトの型。
パラメーター
Observable オブジェクト。
- onNextAsync
- Func<T,StreamSequenceToken,Task>
IAsyncObserver.OnNextAsync に対して呼び出される Delegte。
- token
- StreamSequenceToken
サブスクリプションを開始するオフセットとして使用されるストリーム シーケンス。
- filterFunc
- StreamFilterPredicate
このサブスクリプションに適用するフィルター
- filterData
- Object
filterFunc に渡されるデータ オブジェクト。 これには通常、フィルター処理の決定を行うために filterFunc に必要なパラメーターが含まれます。
戻り値
サブスクリプションを表す StreamSubscriptionHandle の promise。 コンシューマーは、このハンドルを使用してサブスクライブを解除できます。 サブスクリプションが明示的にサブスクライブ解除されていない限り、サブスクリプションはアクティブなままになります。
例外
指定されたストリーム フィルター関数が適していない場合にスローされます。 通常、これは静的メソッドではないのでです。