Compartir a través de


AsyncBatchObservableExtensions.SubscribeAsync Método

Definición

Sobrecargas

SubscribeAsync<T>(IAsyncBatchObservable<T>, Func<IList<SequentialItem<T>>,Task>)

Suscríbase a un consumidor a este observable mediante delegados. Este método es un asistente para IAsyncBatchObservable.SubscribeAsync que permite a la clase de suscripción insertar los métodos de controlador en lugar de requerir una instancia de IAsyncBatchObserver.

SubscribeAsync<T>(IAsyncBatchObservable<T>, Func<IList<SequentialItem<T>>,Task>, Func<Exception,Task>)

Suscríbase a un consumidor a este observable mediante delegados. Este método es un asistente para IAsyncBatchObservable.SubscribeAsync que permite a la clase de suscripción insertar los métodos de controlador en lugar de requerir una instancia de IAsyncBatchObserver.

SubscribeAsync<T>(IAsyncBatchObservable<T>, Func<IList<SequentialItem<T>>,Task>, Func<Task>)

Suscríbase a un consumidor a este observable mediante delegados. Este método es un asistente para IAsyncBatchObservable.SubscribeAsync que permite a la clase de suscripción insertar los métodos de controlador en lugar de requerir una instancia de IAsyncBatchObserver.

SubscribeAsync<T>(IAsyncBatchObservable<T>, Func<IList<SequentialItem<T>>,Task>, Func<Exception,Task>, Func<Task>)

Suscríbase a un consumidor a este observable mediante delegados. Este método es un asistente para IAsyncBatchObservable.SubscribeAsync que permite a la clase de suscripción insertar los métodos de controlador en lugar de requerir una instancia de IAsyncBatchObserver.

SubscribeAsync<T>(IAsyncBatchObservable<T>, Func<IList<SequentialItem<T>>,Task>)

Source:
AsyncBatchObservableExtensions.cs

Suscríbase a un consumidor a este observable mediante delegados. Este método es un asistente para IAsyncBatchObservable.SubscribeAsync que permite a la clase de suscripción insertar los métodos de controlador en lugar de requerir una instancia de 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))

Parámetros de tipo

T

Tipo de objeto generado por el observable.

Parámetros

obs
IAsyncBatchObservable<T>

Objeto Observable.

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

Delegado al que se llama para IAsyncBatchObserver.OnNextAsync.

Devoluciones

Promesa de streamSubscriptionHandle que representa la suscripción. El consumidor puede cancelar la suscripción mediante este identificador. La suscripción permanece activa siempre que no se cancele explícitamente la suscripción.

Se aplica a

SubscribeAsync<T>(IAsyncBatchObservable<T>, Func<IList<SequentialItem<T>>,Task>, Func<Exception,Task>)

Source:
AsyncBatchObservableExtensions.cs

Suscríbase a un consumidor a este observable mediante delegados. Este método es un asistente para IAsyncBatchObservable.SubscribeAsync que permite a la clase de suscripción insertar los métodos de controlador en lugar de requerir una instancia de 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))

Parámetros de tipo

T

Tipo de objeto generado por el observable.

Parámetros

obs
IAsyncBatchObservable<T>

Objeto Observable.

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

Delegado al que se llama para IAsyncBatchObserver.OnNextAsync.

onErrorAsync
Func<Exception,Task>

Delegado al que se llama para IAsyncBatchObserver.OnErrorAsync.

Devoluciones

Promesa de streamSubscriptionHandle que representa la suscripción. El consumidor puede cancelar la suscripción mediante este identificador. La suscripción permanece activa siempre que no se cancele explícitamente la suscripción.

Se aplica a

SubscribeAsync<T>(IAsyncBatchObservable<T>, Func<IList<SequentialItem<T>>,Task>, Func<Task>)

Source:
AsyncBatchObservableExtensions.cs

Suscríbase a un consumidor a este observable mediante delegados. Este método es un asistente para IAsyncBatchObservable.SubscribeAsync que permite a la clase de suscripción insertar los métodos de controlador en lugar de requerir una instancia de 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))

Parámetros de tipo

T

Tipo de objeto generado por el observable.

Parámetros

obs
IAsyncBatchObservable<T>

Objeto Observable.

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

Delegado al que se llama para IAsyncBatchObserver.OnNextAsync.

onCompletedAsync
Func<Task>

Delegado al que se llama para IAsyncBatchObserver.OnCompletedAsync.

Devoluciones

Promesa de streamSubscriptionHandle que representa la suscripción. El consumidor puede cancelar la suscripción mediante este identificador. La suscripción permanece activa siempre que no se cancele explícitamente la suscripción.

Se aplica a

SubscribeAsync<T>(IAsyncBatchObservable<T>, Func<IList<SequentialItem<T>>,Task>, Func<Exception,Task>, Func<Task>)

Source:
AsyncBatchObservableExtensions.cs

Suscríbase a un consumidor a este observable mediante delegados. Este método es un asistente para IAsyncBatchObservable.SubscribeAsync que permite a la clase de suscripción insertar los métodos de controlador en lugar de requerir una instancia de 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))

Parámetros de tipo

T

Tipo de objeto generado por el observable.

Parámetros

obs
IAsyncBatchObservable<T>

Objeto Observable.

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

Delegado al que se llama para IAsyncBatchObserver.OnNextAsync.

onErrorAsync
Func<Exception,Task>

Delegado al que se llama para IAsyncBatchObserver.OnErrorAsync.

onCompletedAsync
Func<Task>

Delegado al que se llama para IAsyncBatchObserver.OnCompletedAsync.

Devoluciones

Promesa de streamSubscriptionHandle que representa la suscripción. El consumidor puede cancelar la suscripción mediante este identificador. La suscripción permanece activa siempre que no se cancele explícitamente la suscripción.

Se aplica a