Partager via


AsyncBatchObservableExtensions.SubscribeAsync Méthode

Définition

Surcharges

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

Abonnez un consommateur à cette observable à l’aide de délégués. Cette méthode est une assistance pour IAsyncBatchObservable.SubscribeAsync permettant à la classe d’abonnement d’inliner les méthodes de gestionnaire au lieu d’exiger une instance d’IAsyncBatchObserver.

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

Abonnez un consommateur à cette observable à l’aide de délégués. Cette méthode est une assistance pour IAsyncBatchObservable.SubscribeAsync permettant à la classe d’abonnement d’inliner les méthodes de gestionnaire au lieu d’exiger une instance d’IAsyncBatchObserver.

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

Abonnez un consommateur à cette observable à l’aide de délégués. Cette méthode est une assistance pour IAsyncBatchObservable.SubscribeAsync permettant à la classe d’abonnement d’inliner les méthodes de gestionnaire au lieu d’exiger une instance d’IAsyncBatchObserver.

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

Abonnez un consommateur à cette observable à l’aide de délégués. Cette méthode est une assistance pour IAsyncBatchObservable.SubscribeAsync permettant à la classe d’abonnement d’inliner les méthodes de gestionnaire au lieu d’exiger une instance d’IAsyncBatchObserver.

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

Source:
AsyncBatchObservableExtensions.cs

Abonnez un consommateur à cette observable à l’aide de délégués. Cette méthode est une assistance pour IAsyncBatchObservable.SubscribeAsync permettant à la classe d’abonnement d’inliner les méthodes de gestionnaire au lieu d’exiger une instance d’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))

Paramètres de type

T

Type d’objet produit par l’observable.

Paramètres

obs
IAsyncBatchObservable<T>

Objet Observable.

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

Délégué appelé pour IAsyncBatchObserver.OnNextAsync.

Retours

Promesse d’un StreamSubscriptionHandle qui représente l’abonnement. Le consommateur peut se désabonner à l’aide de ce handle. L’abonnement reste actif tant qu’il n’est pas explicitement désinscrit.

S’applique à

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

Source:
AsyncBatchObservableExtensions.cs

Abonnez un consommateur à cette observable à l’aide de délégués. Cette méthode est une assistance pour IAsyncBatchObservable.SubscribeAsync permettant à la classe d’abonnement d’inliner les méthodes de gestionnaire au lieu d’exiger une instance d’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))

Paramètres de type

T

Type d’objet produit par l’observable.

Paramètres

obs
IAsyncBatchObservable<T>

Objet Observable.

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

Délégué appelé pour IAsyncBatchObserver.OnNextAsync.

onErrorAsync
Func<Exception,Task>

Délégué appelé pour IAsyncBatchObserver.OnErrorAsync.

Retours

Promesse d’un StreamSubscriptionHandle qui représente l’abonnement. Le consommateur peut se désabonner à l’aide de ce handle. L’abonnement reste actif tant qu’il n’est pas explicitement désinscrit.

S’applique à

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

Source:
AsyncBatchObservableExtensions.cs

Abonnez un consommateur à cette observable à l’aide de délégués. Cette méthode est une assistance pour IAsyncBatchObservable.SubscribeAsync permettant à la classe d’abonnement d’inliner les méthodes de gestionnaire au lieu d’exiger une instance d’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))

Paramètres de type

T

Type d’objet produit par l’observable.

Paramètres

obs
IAsyncBatchObservable<T>

Objet Observable.

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

Délégué appelé pour IAsyncBatchObserver.OnNextAsync.

onCompletedAsync
Func<Task>

Délégué appelé pour IAsyncBatchObserver.OnCompletedAsync.

Retours

Promesse d’un StreamSubscriptionHandle qui représente l’abonnement. Le consommateur peut se désabonner à l’aide de ce handle. L’abonnement reste actif tant qu’il n’est pas explicitement désinscrit.

S’applique à

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

Source:
AsyncBatchObservableExtensions.cs

Abonnez un consommateur à cette observable à l’aide de délégués. Cette méthode est une assistance pour IAsyncBatchObservable.SubscribeAsync permettant à la classe d’abonnement d’inliner les méthodes de gestionnaire au lieu d’exiger une instance d’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))

Paramètres de type

T

Type d’objet produit par l’observable.

Paramètres

obs
IAsyncBatchObservable<T>

Objet Observable.

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

Délégué appelé pour IAsyncBatchObserver.OnNextAsync.

onErrorAsync
Func<Exception,Task>

Délégué appelé pour IAsyncBatchObserver.OnErrorAsync.

onCompletedAsync
Func<Task>

Délégué appelé pour IAsyncBatchObserver.OnCompletedAsync.

Retours

Promesse d’un StreamSubscriptionHandle qui représente l’abonnement. Le consommateur peut se désabonner à l’aide de ce handle. L’abonnement reste actif tant qu’il n’est pas explicitement désinscrit.

S’applique à