AsyncBatchObservableExtensions.SubscribeAsync Метод

Определение

Пространство имен:

Orleans.Streams

Сборка:

Orleans.Streaming.dll

Пакет:

Microsoft.Orleans.Streaming v8.2.0

Перегрузки

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

Тип объекта, создаваемого наблюдаемым объектом.

Параметры

obs

IAsyncBatchObservable<T>

Объект Observable.

onNextAsync

Func<IList<SequentialItem<T>>,Task>

Делегат, который вызывается для IAsyncBatchObserver.OnNextAsync.

Возвращаемое значение

Task<StreamSubscriptionHandle<T>>

Обещание для StreamSubscriptionHandle, представляющего подписку. Потребитель может отменить подписку с помощью этого дескриптора. Подписка остается активной до тех пор, пока она не будет явно отменена.

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

Тип объекта, создаваемого наблюдаемым объектом.

Параметры

obs

IAsyncBatchObservable<T>

Объект Observable.

onNextAsync

Func<IList<SequentialItem<T>>,Task>

Делегат, который вызывается для IAsyncBatchObserver.OnNextAsync.

onErrorAsync

Func<Exception,Task>

Делегат, который вызывается для IAsyncBatchObserver.OnErrorAsync.

Возвращаемое значение

Task<StreamSubscriptionHandle<T>>

Обещание для StreamSubscriptionHandle, представляющего подписку. Потребитель может отменить подписку с помощью этого дескриптора. Подписка остается активной до тех пор, пока она не будет явно отменена.

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

Тип объекта, создаваемого наблюдаемым объектом.

Параметры

obs

IAsyncBatchObservable<T>

Объект Observable.

onNextAsync

Func<IList<SequentialItem<T>>,Task>

Делегат, который вызывается для IAsyncBatchObserver.OnNextAsync.

onCompletedAsync

Func<Task>

Делегат, вызываемый для IAsyncBatchObserver.OnCompletedAsync.

Возвращаемое значение

Task<StreamSubscriptionHandle<T>>

Обещание для StreamSubscriptionHandle, представляющего подписку. Потребитель может отменить подписку с помощью этого дескриптора. Подписка остается активной до тех пор, пока она не будет явно отменена.

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

Тип объекта, создаваемого наблюдаемым объектом.

Параметры

obs

IAsyncBatchObservable<T>

Объект Observable.

onNextAsync

Func<IList<SequentialItem<T>>,Task>

Делегат, который вызывается для IAsyncBatchObserver.OnNextAsync.

onErrorAsync

Func<Exception,Task>

Делегат, который вызывается для IAsyncBatchObserver.OnErrorAsync.

onCompletedAsync

Func<Task>

Делегат, вызываемый для IAsyncBatchObserver.OnCompletedAsync.

Возвращаемое значение

Task<StreamSubscriptionHandle<T>>

Обещание для StreamSubscriptionHandle, представляющего подписку. Потребитель может отменить подписку с помощью этого дескриптора. Подписка остается активной до тех пор, пока она не будет явно отменена.