Compartilhar via


AsyncBatchObservableExtensions.SubscribeAsync Método

Definição

Sobrecargas

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

Assine um consumidor para este observável usando delegados. Esse método é um auxiliar para iAsyncBatchObservable.SubscribeAsync, permitindo que a classe de assinatura inline os métodos do manipulador em vez de exigir uma instância de IAsyncBatchObserver.

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

Assine um consumidor para este observável usando delegados. Esse método é um auxiliar para iAsyncBatchObservable.SubscribeAsync, permitindo que a classe de assinatura inline os métodos do manipulador em vez de exigir uma instância de IAsyncBatchObserver.

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

Assine um consumidor para este observável usando delegados. Esse método é um auxiliar para iAsyncBatchObservable.SubscribeAsync, permitindo que a classe de assinatura inline os métodos do manipulador em vez de exigir uma instância de IAsyncBatchObserver.

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

Assine um consumidor para este observável usando delegados. Esse método é um auxiliar para iAsyncBatchObservable.SubscribeAsync, permitindo que a classe de assinatura inline os métodos do manipulador em vez de exigir uma instância de IAsyncBatchObserver.

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

Origem:
AsyncBatchObservableExtensions.cs

Assine um consumidor para este observável usando delegados. Esse método é um auxiliar para iAsyncBatchObservable.SubscribeAsync, permitindo que a classe de assinatura inline os métodos do manipulador em vez de exigir uma instância 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

O tipo de objeto produzido pelo observável.

Parâmetros

obs
IAsyncBatchObservable<T>

O objeto Observável.

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

Delegado que é chamado para IAsyncBatchObserver.OnNextAsync.

Retornos

Uma promessa para um StreamSubscriptionHandle que representa a assinatura. O consumidor pode cancelar a assinatura usando esse identificador. A assinatura permanece ativa desde que não seja explicitamente cancelada.

Aplica-se a

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

Origem:
AsyncBatchObservableExtensions.cs

Assine um consumidor para este observável usando delegados. Esse método é um auxiliar para iAsyncBatchObservable.SubscribeAsync, permitindo que a classe de assinatura inline os métodos do manipulador em vez de exigir uma instância 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

O tipo de objeto produzido pelo observável.

Parâmetros

obs
IAsyncBatchObservable<T>

O objeto Observável.

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

Delegado que é chamado para IAsyncBatchObserver.OnNextAsync.

onErrorAsync
Func<Exception,Task>

Delegado que é chamado para IAsyncBatchObserver.OnErrorAsync.

Retornos

Uma promessa para um StreamSubscriptionHandle que representa a assinatura. O consumidor pode cancelar a assinatura usando esse identificador. A assinatura permanece ativa desde que não seja explicitamente cancelada.

Aplica-se a

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

Origem:
AsyncBatchObservableExtensions.cs

Assine um consumidor para este observável usando delegados. Esse método é um auxiliar para iAsyncBatchObservable.SubscribeAsync, permitindo que a classe de assinatura inline os métodos do manipulador em vez de exigir uma instância 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

O tipo de objeto produzido pelo observável.

Parâmetros

obs
IAsyncBatchObservable<T>

O objeto Observável.

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

Delegado que é chamado para IAsyncBatchObserver.OnNextAsync.

onCompletedAsync
Func<Task>

Delegado chamado para IAsyncBatchObserver.OnCompletedAsync.

Retornos

Uma promessa para um StreamSubscriptionHandle que representa a assinatura. O consumidor pode cancelar a assinatura usando esse identificador. A assinatura permanece ativa desde que não seja explicitamente cancelada.

Aplica-se a

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

Origem:
AsyncBatchObservableExtensions.cs

Assine um consumidor para este observável usando delegados. Esse método é um auxiliar para iAsyncBatchObservable.SubscribeAsync, permitindo que a classe de assinatura inline os métodos do manipulador em vez de exigir uma instância 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

O tipo de objeto produzido pelo observável.

Parâmetros

obs
IAsyncBatchObservable<T>

O objeto Observável.

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

Delegado que é chamado para IAsyncBatchObserver.OnNextAsync.

onErrorAsync
Func<Exception,Task>

Delegado que é chamado para IAsyncBatchObserver.OnErrorAsync.

onCompletedAsync
Func<Task>

Delegado chamado para IAsyncBatchObserver.OnCompletedAsync.

Retornos

Uma promessa para um StreamSubscriptionHandle que representa a assinatura. O consumidor pode cancelar a assinatura usando esse identificador. A assinatura permanece ativa desde que não seja explicitamente cancelada.

Aplica-se a