AsyncBatchObservableExtensions.SubscribeAsync Метод
Определение
Важно!
Некоторые сведения относятся к предварительной версии продукта, в которую до выпуска могут быть внесены существенные изменения. Майкрософт не предоставляет никаких гарантий, явных или подразумеваемых, относительно приведенных здесь сведений.
Перегрузки
| 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>)
- Исходный код:
- AsyncBatchObservableExtensions.cs
Подпишите потребителя на этот наблюдаемый с помощью делегатов. Этот метод является вспомогательным методом для 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, представляющего подписку. Потребитель может отменить подписку с помощью этого дескриптора. Подписка остается активной до тех пор, пока она не будет явно отменена.
Применяется к
SubscribeAsync<T>(IAsyncBatchObservable<T>, Func<IList<SequentialItem<T>>,Task>, Func<Exception,Task>)
- Исходный код:
- AsyncBatchObservableExtensions.cs
Подпишите потребителя на этот наблюдаемый с помощью делегатов. Этот метод является вспомогательным методом для 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, представляющего подписку. Потребитель может отменить подписку с помощью этого дескриптора. Подписка остается активной до тех пор, пока она не будет явно отменена.
Применяется к
SubscribeAsync<T>(IAsyncBatchObservable<T>, Func<IList<SequentialItem<T>>,Task>, Func<Task>)
- Исходный код:
- AsyncBatchObservableExtensions.cs
Подпишите потребителя на этот наблюдаемый с помощью делегатов. Этот метод является вспомогательным методом для 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, представляющего подписку. Потребитель может отменить подписку с помощью этого дескриптора. Подписка остается активной до тех пор, пока она не будет явно отменена.
Применяется к
SubscribeAsync<T>(IAsyncBatchObservable<T>, Func<IList<SequentialItem<T>>,Task>, Func<Exception,Task>, Func<Task>)
- Исходный код:
- AsyncBatchObservableExtensions.cs
Подпишите потребителя на этот наблюдаемый с помощью делегатов. Этот метод является вспомогательным методом для 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, представляющего подписку. Потребитель может отменить подписку с помощью этого дескриптора. Подписка остается активной до тех пор, пока она не будет явно отменена.