Partager via

AsyncObservableExtensions.SubscribeAsync Méthode

  • Référence

Définition

Espace de noms:
Orleans.Streams
Assembly:
Orleans.dll
Assembly:
Orleans.Core.Abstractions.dll
Assembly:
Orleans.Streaming.dll
Paquet:
Microsoft.Orleans.Core v1.5.10
Paquet:
Microsoft.Orleans.Core.Abstractions v2.4.5
Paquet:
Microsoft.Orleans.Core.Abstractions v3.6.5
Paquet:
Microsoft.Orleans.Streaming v7.2.5
Paquet:
Microsoft.Orleans.Streaming v8.0.0
Paquet:
Microsoft.Orleans.Streaming v8.1.0
Paquet:
Microsoft.Orleans.Streaming v8.2.0

Surcharges

SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>)

Abonnez un consommateur à cette observable à l’aide de délégués. Cette méthode est une assistance pour IAsyncObservable.SubscribeAsync qui permet à la classe d’abonnement d’inliner les méthodes de gestionnaire au lieu d’exiger une instance d’IAsyncObserver.
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, StreamSequenceToken)

Abonnez un consommateur à cette observable à l’aide de délégués. Cette méthode est une assistance pour IAsyncObservable.SubscribeAsync qui permet à la classe d’abonnement d’inliner les méthodes de gestionnaire au lieu d’exiger une instance d’IAsyncObserver.
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>)

Abonnez un consommateur à cette observable à l’aide de délégués. Cette méthode est une assistance pour IAsyncObservable.SubscribeAsync qui permet à la classe d’abonnement d’inliner les méthodes de gestionnaire au lieu d’exiger une instance d’IAsyncObserver.
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Task>)

Abonnez un consommateur à cette observable à l’aide de délégués. Cette méthode est une assistance pour IAsyncObservable.SubscribeAsync qui permet à la classe d’abonnement d’inliner les méthodes de gestionnaire au lieu d’exiger une instance d’IAsyncObserver.
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, StreamSequenceToken)

Abonnez un consommateur à cette observable à l’aide de délégués. Cette méthode est une assistance pour IAsyncObservable.SubscribeAsync qui permet à la classe d’abonnement d’inliner les méthodes de gestionnaire au lieu d’exiger une instance d’IAsyncObserver.
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,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 IAsyncObservable.SubscribeAsync qui permet à la classe d’abonnement d’inliner les méthodes de gestionnaire au lieu d’exiger une instance d’IAsyncObserver.
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Task>, StreamSequenceToken)

Abonnez un consommateur à cette observable à l’aide de délégués. Cette méthode est une assistance pour IAsyncObservable.SubscribeAsync qui permet à la classe d’abonnement d’inliner les méthodes de gestionnaire au lieu d’exiger une instance d’IAsyncObserver.
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, StreamSequenceToken, StreamFilterPredicate, Object)

Abonnez un consommateur à cette observable à l’aide de délégués. Cette méthode est une assistance pour IAsyncObservable.SubscribeAsync qui permet à la classe d’abonnement d’inliner les méthodes de gestionnaire au lieu d’exiger une instance d’IAsyncObserver.
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, Func<Task>, StreamSequenceToken)

Abonnez un consommateur à cette observable à l’aide de délégués. Cette méthode est une assistance pour IAsyncObservable.SubscribeAsync qui permet à la classe d’abonnement d’inliner les méthodes de gestionnaire au lieu d’exiger une instance d’IAsyncObserver.
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, StreamSequenceToken, StreamFilterPredicate, Object)

Abonnez un consommateur à cette observable à l’aide de délégués. Cette méthode est une assistance pour IAsyncObservable.SubscribeAsync qui permet à la classe d’abonnement d’inliner les méthodes de gestionnaire au lieu d’exiger une instance d’IAsyncObserver.
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Task>, StreamSequenceToken, StreamFilterPredicate, Object)

Abonnez un consommateur à cette observable à l’aide de délégués. Cette méthode est une assistance pour IAsyncObservable.SubscribeAsync qui permet à la classe d’abonnement d’inliner les méthodes de gestionnaire au lieu d’exiger une instance d’IAsyncObserver.
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken, Task>, Func<Exception,Task>, Func<Task>, StreamSequenceToken, StreamFilterPredicate, Object)

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

SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>)

Source:
AsyncObservableExtensions.cs

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

public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T> (this Orleans.Streams.IAsyncObservable<T> obs, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync);
static member SubscribeAsync : Orleans.Streams.IAsyncObservable<'T> * Func<'T, Orleans.Streams.StreamSequenceToken, System.Threading.Tasks.Task> -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>>
<Extension()>
Public Function SubscribeAsync(Of T) (obs As IAsyncObservable(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task)) As Task(Of StreamSubscriptionHandle(Of T))

Paramètres de type

T

Type d’objet produit par l’observable.

Paramètres

obs
IAsyncObservable<T>

Objet Observable.

onNextAsync
Func<T,StreamSequenceToken,Task>

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

Retours

Task<StreamSubscriptionHandle<T>>

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>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, StreamSequenceToken)

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

public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T> (this Orleans.Streams.IAsyncObservable<T> obs, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync, Orleans.Streams.StreamSequenceToken token);
static member SubscribeAsync : Orleans.Streams.IAsyncObservable<'T> * Func<'T, Orleans.Streams.StreamSequenceToken, System.Threading.Tasks.Task> * Orleans.Streams.StreamSequenceToken -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>>
<Extension()>
Public Function SubscribeAsync(Of T) (obs As IAsyncObservable(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task), token As StreamSequenceToken) As Task(Of StreamSubscriptionHandle(Of T))

Paramètres de type

T

Type d’objet produit par l’observable.

Paramètres

obs
IAsyncObservable<T>

Objet Observable.

onNextAsync
Func<T,StreamSequenceToken,Task>

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

token
StreamSequenceToken

Séquence de flux à utiliser comme décalage pour démarrer l’abonnement.

Retours

Task<StreamSubscriptionHandle<T>>

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.

Exceptions

ArgumentException

Levée si la fonction de filtre de flux fournie ne convient pas. Cela est généralement dû au fait qu’il ne s’agit pas d’une méthode statique.

S’applique à

SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>)

Source:
AsyncObservableExtensions.cs

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

public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T> (this Orleans.Streams.IAsyncObservable<T> obs, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync, Func<Exception,System.Threading.Tasks.Task> onErrorAsync);
static member SubscribeAsync : Orleans.Streams.IAsyncObservable<'T> * Func<'T, Orleans.Streams.StreamSequenceToken, 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 IAsyncObservable(Of T), onNextAsync As Func(Of T, StreamSequenceToken, 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
IAsyncObservable<T>

Objet Observable.

onNextAsync
Func<T,StreamSequenceToken,Task>

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

onErrorAsync
Func<Exception,Task>

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

Retours

Task<StreamSubscriptionHandle<T>>

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>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Task>)

Source:
AsyncObservableExtensions.cs

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

public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T> (this Orleans.Streams.IAsyncObservable<T> obs, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync, Func<System.Threading.Tasks.Task> onCompletedAsync);
static member SubscribeAsync : Orleans.Streams.IAsyncObservable<'T> * Func<'T, Orleans.Streams.StreamSequenceToken, 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 IAsyncObservable(Of T), onNextAsync As Func(Of T, StreamSequenceToken, 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
IAsyncObservable<T>

Objet Observable.

onNextAsync
Func<T,StreamSequenceToken,Task>

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

onCompletedAsync
Func<Task>

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

Retours

Task<StreamSubscriptionHandle<T>>

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>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, StreamSequenceToken)

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

public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T> (this Orleans.Streams.IAsyncObservable<T> obs, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync, Func<Exception,System.Threading.Tasks.Task> onErrorAsync, Orleans.Streams.StreamSequenceToken token);
static member SubscribeAsync : Orleans.Streams.IAsyncObservable<'T> * Func<'T, Orleans.Streams.StreamSequenceToken, System.Threading.Tasks.Task> * Func<Exception, System.Threading.Tasks.Task> * Orleans.Streams.StreamSequenceToken -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>>
<Extension()>
Public Function SubscribeAsync(Of T) (obs As IAsyncObservable(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task), onErrorAsync As Func(Of Exception, Task), token As StreamSequenceToken) As Task(Of StreamSubscriptionHandle(Of T))

Paramètres de type

T

Type d’objet produit par l’observable.

Paramètres

obs
IAsyncObservable<T>

Objet Observable.

onNextAsync
Func<T,StreamSequenceToken,Task>

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

onErrorAsync
Func<Exception,Task>

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

token
StreamSequenceToken

Séquence de flux à utiliser comme décalage pour démarrer l’abonnement.

Retours

Task<StreamSubscriptionHandle<T>>

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.

Exceptions

ArgumentException

Levée si la fonction de filtre de flux fournie ne convient pas. Cela est généralement dû au fait qu’il ne s’agit pas d’une méthode statique.

S’applique à

SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, Func<Task>)

Source:
AsyncObservableExtensions.cs

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

public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T> (this Orleans.Streams.IAsyncObservable<T> obs, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync, Func<Exception,System.Threading.Tasks.Task> onErrorAsync, Func<System.Threading.Tasks.Task> onCompletedAsync);
static member SubscribeAsync : Orleans.Streams.IAsyncObservable<'T> * Func<'T, Orleans.Streams.StreamSequenceToken, 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 IAsyncObservable(Of T), onNextAsync As Func(Of T, StreamSequenceToken, 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
IAsyncObservable<T>

Objet Observable.

onNextAsync
Func<T,StreamSequenceToken,Task>

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

onErrorAsync
Func<Exception,Task>

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

onCompletedAsync
Func<Task>

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

Retours

Task<StreamSubscriptionHandle<T>>

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>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Task>, StreamSequenceToken)

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

public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T> (this Orleans.Streams.IAsyncObservable<T> obs, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync, Func<System.Threading.Tasks.Task> onCompletedAsync, Orleans.Streams.StreamSequenceToken token);
static member SubscribeAsync : Orleans.Streams.IAsyncObservable<'T> * Func<'T, Orleans.Streams.StreamSequenceToken, System.Threading.Tasks.Task> * Func<System.Threading.Tasks.Task> * Orleans.Streams.StreamSequenceToken -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>>
<Extension()>
Public Function SubscribeAsync(Of T) (obs As IAsyncObservable(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task), onCompletedAsync As Func(Of Task), token As StreamSequenceToken) As Task(Of StreamSubscriptionHandle(Of T))

Paramètres de type

T

Type d’objet produit par l’observable.

Paramètres

obs
IAsyncObservable<T>

Objet Observable.

onNextAsync
Func<T,StreamSequenceToken,Task>

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

onCompletedAsync
Func<Task>

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

token
StreamSequenceToken

Séquence de flux à utiliser comme décalage pour démarrer l’abonnement.

Retours

Task<StreamSubscriptionHandle<T>>

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.

Exceptions

ArgumentException

Levée si la fonction de filtre de flux fournie ne convient pas. Cela est généralement dû au fait qu’il ne s’agit pas d’une méthode statique.

S’applique à

SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, StreamSequenceToken, StreamFilterPredicate, Object)

Source:
AsyncObservableExtensions.cs

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

public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T> (this Orleans.Streams.IAsyncObservable<T> obs, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync, Orleans.Streams.StreamSequenceToken token, Orleans.Streams.StreamFilterPredicate filterFunc = default, object filterData = default);
static member SubscribeAsync : Orleans.Streams.IAsyncObservable<'T> * Func<'T, Orleans.Streams.StreamSequenceToken, System.Threading.Tasks.Task> * Orleans.Streams.StreamSequenceToken * Orleans.Streams.StreamFilterPredicate * obj -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>>
<Extension()>
Public Function SubscribeAsync(Of T) (obs As IAsyncObservable(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task), token As StreamSequenceToken, Optional filterFunc As StreamFilterPredicate = Nothing, Optional filterData As Object = Nothing) As Task(Of StreamSubscriptionHandle(Of T))

Paramètres de type

T

Type d’objet produit par l’observable.

Paramètres

obs
IAsyncObservable<T>

Objet Observable.

onNextAsync
Func<T,StreamSequenceToken,Task>

Délégation appelée pour IAsyncObserver.OnNextAsync.

token
StreamSequenceToken

Séquence de flux à utiliser comme décalage pour démarrer l’abonnement.

filterFunc
StreamFilterPredicate

Filtre à appliquer pour cet abonnement

filterData
Object

Objet de données qui sera transmis au filterFunc. Il contient généralement tous les paramètres requis par le filterFunc pour prendre la décision de filtrage.

Retours

Task<StreamSubscriptionHandle<T>>

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.

Exceptions

ArgumentException

Levée si la fonction de filtre de flux fournie ne convient pas. Cela est généralement dû au fait qu’il ne s’agit pas d’une méthode statique.

S’applique à

SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, Func<Task>, StreamSequenceToken)

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

public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T> (this Orleans.Streams.IAsyncObservable<T> obs, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync, Func<Exception,System.Threading.Tasks.Task> onErrorAsync, Func<System.Threading.Tasks.Task> onCompletedAsync, Orleans.Streams.StreamSequenceToken token);
static member SubscribeAsync : Orleans.Streams.IAsyncObservable<'T> * Func<'T, Orleans.Streams.StreamSequenceToken, System.Threading.Tasks.Task> * Func<Exception, System.Threading.Tasks.Task> * Func<System.Threading.Tasks.Task> * Orleans.Streams.StreamSequenceToken -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>>
<Extension()>
Public Function SubscribeAsync(Of T) (obs As IAsyncObservable(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task), onErrorAsync As Func(Of Exception, Task), onCompletedAsync As Func(Of Task), token As StreamSequenceToken) As Task(Of StreamSubscriptionHandle(Of T))

Paramètres de type

T

Type d’objet produit par l’observable.

Paramètres

obs
IAsyncObservable<T>

Objet Observable.

onNextAsync
Func<T,StreamSequenceToken,Task>

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

onErrorAsync
Func<Exception,Task>

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

onCompletedAsync
Func<Task>

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

token
StreamSequenceToken

Séquence de flux à utiliser comme décalage pour démarrer l’abonnement.

Retours

Task<StreamSubscriptionHandle<T>>

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.

Exceptions

ArgumentException

Levée si la fonction de filtre de flux fournie ne convient pas. Cela est généralement dû au fait qu’il ne s’agit pas d’une méthode statique.

S’applique à

SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, StreamSequenceToken, StreamFilterPredicate, Object)

Source:
AsyncObservableExtensions.cs

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

public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T> (this Orleans.Streams.IAsyncObservable<T> obs, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync, Func<Exception,System.Threading.Tasks.Task> onErrorAsync, Orleans.Streams.StreamSequenceToken token, Orleans.Streams.StreamFilterPredicate filterFunc = default, object filterData = default);
static member SubscribeAsync : Orleans.Streams.IAsyncObservable<'T> * Func<'T, Orleans.Streams.StreamSequenceToken, System.Threading.Tasks.Task> * Func<Exception, System.Threading.Tasks.Task> * Orleans.Streams.StreamSequenceToken * Orleans.Streams.StreamFilterPredicate * obj -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>>
<Extension()>
Public Function SubscribeAsync(Of T) (obs As IAsyncObservable(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task), onErrorAsync As Func(Of Exception, Task), token As StreamSequenceToken, Optional filterFunc As StreamFilterPredicate = Nothing, Optional filterData As Object = Nothing) As Task(Of StreamSubscriptionHandle(Of T))

Paramètres de type

T

Type d’objet produit par l’observable.

Paramètres

obs
IAsyncObservable<T>

Objet Observable.

onNextAsync
Func<T,StreamSequenceToken,Task>

Délégation appelée pour IAsyncObserver.OnNextAsync.

onErrorAsync
Func<Exception,Task>

Délégation appelée pour IAsyncObserver.OnErrorAsync.

token
StreamSequenceToken

Séquence de flux à utiliser comme décalage pour démarrer l’abonnement.

filterFunc
StreamFilterPredicate

Filtre à appliquer pour cet abonnement

filterData
Object

Objet de données qui sera transmis au filterFunc. Il contient généralement tous les paramètres requis par le filterFunc pour prendre la décision de filtrage.

Retours

Task<StreamSubscriptionHandle<T>>

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.

Exceptions

ArgumentException

Levée si la fonction de filtre de flux fournie ne convient pas. Cela est généralement dû au fait qu’il ne s’agit pas d’une méthode statique.

S’applique à

SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Task>, StreamSequenceToken, StreamFilterPredicate, Object)

Source:
AsyncObservableExtensions.cs

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

public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T> (this Orleans.Streams.IAsyncObservable<T> obs, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync, Func<System.Threading.Tasks.Task> onCompletedAsync, Orleans.Streams.StreamSequenceToken token, Orleans.Streams.StreamFilterPredicate filterFunc = default, object filterData = default);
static member SubscribeAsync : Orleans.Streams.IAsyncObservable<'T> * Func<'T, Orleans.Streams.StreamSequenceToken, System.Threading.Tasks.Task> * Func<System.Threading.Tasks.Task> * Orleans.Streams.StreamSequenceToken * Orleans.Streams.StreamFilterPredicate * obj -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>>
<Extension()>
Public Function SubscribeAsync(Of T) (obs As IAsyncObservable(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task), onCompletedAsync As Func(Of Task), token As StreamSequenceToken, Optional filterFunc As StreamFilterPredicate = Nothing, Optional filterData As Object = Nothing) As Task(Of StreamSubscriptionHandle(Of T))

Paramètres de type

T

Type d’objet produit par l’observable.

Paramètres

obs
IAsyncObservable<T>

Objet Observable.

onNextAsync
Func<T,StreamSequenceToken,Task>

Délégation appelée pour IAsyncObserver.OnNextAsync.

onCompletedAsync
Func<Task>

Délégation appelée pour IAsyncObserver.OnCompletedAsync.

token
StreamSequenceToken

Séquence de flux à utiliser comme décalage pour démarrer l’abonnement.

filterFunc
StreamFilterPredicate

Filtre à appliquer pour cet abonnement

filterData
Object

Objet de données qui sera transmis au filterFunc. Il contient généralement tous les paramètres requis par le filterFunc pour prendre la décision de filtrage.

Retours

Task<StreamSubscriptionHandle<T>>

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.

Exceptions

ArgumentException

Levée si la fonction de filtre de flux fournie ne convient pas. Cela est généralement dû au fait qu’il ne s’agit pas d’une méthode statique.

S’applique à

SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken, Task>, Func<Exception,Task>, Func<Task>, StreamSequenceToken, StreamFilterPredicate, Object)

Source:
AsyncObservableExtensions.cs

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

public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T> (this Orleans.Streams.IAsyncObservable<T> obs, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync, Func<Exception,System.Threading.Tasks.Task> onErrorAsync, Func<System.Threading.Tasks.Task> onCompletedAsync, Orleans.Streams.StreamSequenceToken token, Orleans.Streams.StreamFilterPredicate filterFunc = default, object filterData = default);
static member SubscribeAsync : Orleans.Streams.IAsyncObservable<'T> * Func<'T, Orleans.Streams.StreamSequenceToken, System.Threading.Tasks.Task> * Func<Exception, System.Threading.Tasks.Task> * Func<System.Threading.Tasks.Task> * Orleans.Streams.StreamSequenceToken * Orleans.Streams.StreamFilterPredicate * obj -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>>
<Extension()>
Public Function SubscribeAsync(Of T) (obs As IAsyncObservable(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task), onErrorAsync As Func(Of Exception, Task), onCompletedAsync As Func(Of Task), token As StreamSequenceToken, Optional filterFunc As StreamFilterPredicate = Nothing, Optional filterData As Object = Nothing) As Task(Of StreamSubscriptionHandle(Of T))

Paramètres de type

T

Type d’objet produit par l’observable.

Paramètres

obs
IAsyncObservable<T>

Objet Observable.

onNextAsync
Func<T,StreamSequenceToken,Task>

Délégation appelée pour IAsyncObserver.OnNextAsync.

onErrorAsync
Func<Exception,Task>

Délégation appelée pour IAsyncObserver.OnErrorAsync.

onCompletedAsync
Func<Task>

Délégation appelée pour IAsyncObserver.OnCompletedAsync.

token
StreamSequenceToken

Séquence de flux à utiliser comme décalage pour démarrer l’abonnement.

filterFunc
StreamFilterPredicate

Filtre à appliquer pour cet abonnement

filterData
Object

Objet de données qui sera transmis au filterFunc. Il contient généralement tous les paramètres requis par le filterFunc pour prendre la décision de filtrage.

Retours

Task<StreamSubscriptionHandle<T>>

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.

Exceptions

ArgumentException

Levée si la fonction de filtre de flux fournie ne convient pas. Cela est généralement dû au fait qu’il ne s’agit pas d’une méthode statique.

S’applique à