AsyncBatchObservableExtensions.SubscribeAsync メソッド
定義
重要
一部の情報は、リリース前に大きく変更される可能性があるプレリリースされた製品に関するものです。 Microsoft は、ここに記載されている情報について、明示または黙示を問わず、一切保証しません。
オーバーロード
| SubscribeAsync<T>(IAsyncBatchObservable<T>, Func<IList<SequentialItem<T>>,Task>) |
デリゲートを使用して、コンシューマーをこの監視可能にサブスクライブします。 このメソッドは IAsyncBatchObservable.SubscribeAsync のヘルパーであり、サブスクライブ クラスは IAsyncBatchObserver のインスタンスを必要とするのではなく、ハンドラー メソッドをインライン化できます。 |
| SubscribeAsync<T>(IAsyncBatchObservable<T>, Func<IList<SequentialItem<T>>,Task>, Func<Exception,Task>) |
デリゲートを使用して、コンシューマーをこの監視可能にサブスクライブします。 このメソッドは IAsyncBatchObservable.SubscribeAsync のヘルパーであり、サブスクライブ クラスは IAsyncBatchObserver のインスタンスを必要とするのではなく、ハンドラー メソッドをインライン化できます。 |
| SubscribeAsync<T>(IAsyncBatchObservable<T>, Func<IList<SequentialItem<T>>,Task>, Func<Task>) |
デリゲートを使用して、コンシューマーをこの監視可能にサブスクライブします。 このメソッドは IAsyncBatchObservable.SubscribeAsync のヘルパーであり、サブスクライブ クラスは IAsyncBatchObserver のインスタンスを必要とするのではなく、ハンドラー メソッドをインライン化できます。 |
| SubscribeAsync<T>(IAsyncBatchObservable<T>, Func<IList<SequentialItem<T>>,Task>, Func<Exception,Task>, Func<Task>) |
デリゲートを使用して、コンシューマーをこの監視可能にサブスクライブします。 このメソッドは IAsyncBatchObservable.SubscribeAsync のヘルパーであり、サブスクライブ クラスは IAsyncBatchObserver のインスタンスを必要とするのではなく、ハンドラー メソッドをインライン化できます。 |
SubscribeAsync<T>(IAsyncBatchObservable<T>, Func<IList<SequentialItem<T>>,Task>)
デリゲートを使用して、コンシューマーをこの監視可能にサブスクライブします。 このメソッドは IAsyncBatchObservable.SubscribeAsync のヘルパーであり、サブスクライブ クラスは IAsyncBatchObserver のインスタンスを必要とするのではなく、ハンドラー メソッドをインライン化できます。
public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T> (this Orleans.Streams.IAsyncBatchObservable<T> obs, Func<System.Collections.Generic.IList<Orleans.Streams.SequentialItem<T>>,System.Threading.Tasks.Task> onNextAsync);static member SubscribeAsync : Orleans.Streams.IAsyncBatchObservable<'T> * Func<System.Collections.Generic.IList<Orleans.Streams.SequentialItem<'T>>, System.Threading.Tasks.Task> -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>><Extension()>
Public Function SubscribeAsync(Of T) (obs As IAsyncBatchObservable(Of T), onNextAsync As Func(Of IList(Of SequentialItem(Of T)), Task)) As Task(Of StreamSubscriptionHandle(Of T))型パラメーター
- T
監視可能オブジェクトによって生成されるオブジェクトの型。
パラメーター
Observable オブジェクト。
- onNextAsync
- Func<IList<SequentialItem<T>>,Task>
IAsyncBatchObserver.OnNextAsync に対して呼び出されるデリゲート。
戻り値
サブスクリプションを表す StreamSubscriptionHandle の promise。 コンシューマーは、このハンドルを使用して登録を解除できます。 サブスクリプションが明示的にサブスクライブ解除されていない限り、サブスクリプションはアクティブなままです。
適用対象
SubscribeAsync<T>(IAsyncBatchObservable<T>, Func<IList<SequentialItem<T>>,Task>, Func<Exception,Task>)
デリゲートを使用して、コンシューマーをこの監視可能にサブスクライブします。 このメソッドは IAsyncBatchObservable.SubscribeAsync のヘルパーであり、サブスクライブ クラスは IAsyncBatchObserver のインスタンスを必要とするのではなく、ハンドラー メソッドをインライン化できます。
public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T> (this Orleans.Streams.IAsyncBatchObservable<T> obs, Func<System.Collections.Generic.IList<Orleans.Streams.SequentialItem<T>>,System.Threading.Tasks.Task> onNextAsync, Func<Exception,System.Threading.Tasks.Task> onErrorAsync);static member SubscribeAsync : Orleans.Streams.IAsyncBatchObservable<'T> * Func<System.Collections.Generic.IList<Orleans.Streams.SequentialItem<'T>>, 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 IAsyncBatchObservable(Of T), onNextAsync As Func(Of IList(Of SequentialItem(Of T)), Task), onErrorAsync As Func(Of Exception, Task)) As Task(Of StreamSubscriptionHandle(Of T))型パラメーター
- T
監視可能オブジェクトによって生成されるオブジェクトの型。
パラメーター
Observable オブジェクト。
- onNextAsync
- Func<IList<SequentialItem<T>>,Task>
IAsyncBatchObserver.OnNextAsync に対して呼び出されるデリゲート。
戻り値
サブスクリプションを表す StreamSubscriptionHandle の promise。 コンシューマーは、このハンドルを使用して登録を解除できます。 サブスクリプションが明示的にサブスクライブ解除されていない限り、サブスクリプションはアクティブなままです。
適用対象
SubscribeAsync<T>(IAsyncBatchObservable<T>, Func<IList<SequentialItem<T>>,Task>, Func<Task>)
デリゲートを使用して、コンシューマーをこの監視可能にサブスクライブします。 このメソッドは IAsyncBatchObservable.SubscribeAsync のヘルパーであり、サブスクライブ クラスは IAsyncBatchObserver のインスタンスを必要とするのではなく、ハンドラー メソッドをインライン化できます。
public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T> (this Orleans.Streams.IAsyncBatchObservable<T> obs, Func<System.Collections.Generic.IList<Orleans.Streams.SequentialItem<T>>,System.Threading.Tasks.Task> onNextAsync, Func<System.Threading.Tasks.Task> onCompletedAsync);static member SubscribeAsync : Orleans.Streams.IAsyncBatchObservable<'T> * Func<System.Collections.Generic.IList<Orleans.Streams.SequentialItem<'T>>, 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 IAsyncBatchObservable(Of T), onNextAsync As Func(Of IList(Of SequentialItem(Of T)), Task), onCompletedAsync As Func(Of Task)) As Task(Of StreamSubscriptionHandle(Of T))型パラメーター
- T
監視可能オブジェクトによって生成されるオブジェクトの型。
パラメーター
Observable オブジェクト。
- onNextAsync
- Func<IList<SequentialItem<T>>,Task>
IAsyncBatchObserver.OnNextAsync に対して呼び出されるデリゲート。
戻り値
サブスクリプションを表す StreamSubscriptionHandle の promise。 コンシューマーは、このハンドルを使用して登録を解除できます。 サブスクリプションが明示的にサブスクライブ解除されていない限り、サブスクリプションはアクティブなままです。
適用対象
SubscribeAsync<T>(IAsyncBatchObservable<T>, Func<IList<SequentialItem<T>>,Task>, Func<Exception,Task>, Func<Task>)
デリゲートを使用して、コンシューマーをこの監視可能にサブスクライブします。 このメソッドは IAsyncBatchObservable.SubscribeAsync のヘルパーであり、サブスクライブ クラスは IAsyncBatchObserver のインスタンスを必要とするのではなく、ハンドラー メソッドをインライン化できます。
public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T> (this Orleans.Streams.IAsyncBatchObservable<T> obs, Func<System.Collections.Generic.IList<Orleans.Streams.SequentialItem<T>>,System.Threading.Tasks.Task> onNextAsync, Func<Exception,System.Threading.Tasks.Task> onErrorAsync, Func<System.Threading.Tasks.Task> onCompletedAsync);static member SubscribeAsync : Orleans.Streams.IAsyncBatchObservable<'T> * Func<System.Collections.Generic.IList<Orleans.Streams.SequentialItem<'T>>, 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 IAsyncBatchObservable(Of T), onNextAsync As Func(Of IList(Of SequentialItem(Of T)), Task), onErrorAsync As Func(Of Exception, Task), onCompletedAsync As Func(Of Task)) As Task(Of StreamSubscriptionHandle(Of T))型パラメーター
- T
監視可能オブジェクトによって生成されるオブジェクトの型。
パラメーター
Observable オブジェクト。
- onNextAsync
- Func<IList<SequentialItem<T>>,Task>
IAsyncBatchObserver.OnNextAsync に対して呼び出されるデリゲート。
戻り値
サブスクリプションを表す StreamSubscriptionHandle の promise。 コンシューマーは、このハンドルを使用して登録を解除できます。 サブスクリプションが明示的にサブスクライブ解除されていない限り、サブスクリプションはアクティブなままです。