IAsyncObservable<T>.SubscribeAsync Méthode
Définition
Important
Certaines informations portent sur la préversion du produit qui est susceptible d’être en grande partie modifiée avant sa publication. Microsoft exclut toute garantie, expresse ou implicite, concernant les informations fournies ici.
Surcharges
| SubscribeAsync(IAsyncObserver<T>) |
Abonnez un consommateur à cette observable. |
| SubscribeAsync(IAsyncObserver<T>, StreamSequenceToken, String) |
Abonnez un consommateur à cette observable. |
| SubscribeAsync(IAsyncObserver<T>, StreamSequenceToken, StreamFilterPredicate, Object) |
Abonnez un consommateur à cette observable. |
SubscribeAsync(IAsyncObserver<T>)
- Source:
- IAsyncObservable.cs
Abonnez un consommateur à cette observable.
public System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync (Orleans.Streams.IAsyncObserver<T> observer);abstract member SubscribeAsync : Orleans.Streams.IAsyncObserver<'T> -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>>Public Function SubscribeAsync (observer As IAsyncObserver(Of T)) As Task(Of StreamSubscriptionHandle(Of T))Paramètres
- observer
- IAsyncObserver<T>
Observateur asynchrone à abonner.
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(IAsyncObserver<T>, StreamSequenceToken, String)
Abonnez un consommateur à cette observable.
public System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync (Orleans.Streams.IAsyncObserver<T> observer, Orleans.Streams.StreamSequenceToken? token, string? filterData = default);abstract member SubscribeAsync : Orleans.Streams.IAsyncObserver<'T> * Orleans.Streams.StreamSequenceToken * string -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>>Public Function SubscribeAsync (observer As IAsyncObserver(Of T), token As StreamSequenceToken, Optional filterData As String = Nothing) As Task(Of StreamSubscriptionHandle(Of T))Paramètres
- observer
- IAsyncObserver<T>
Observateur asynchrone à abonner.
- token
- StreamSequenceToken
Séquence de flux à utiliser comme décalage pour démarrer l’abonnement.
- filterData
- String
Objet de données qui sera transmis au filtre.
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(IAsyncObserver<T>, StreamSequenceToken, StreamFilterPredicate, Object)
- Source:
- IAsyncObservable.cs
Abonnez un consommateur à cette observable.
public System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync (Orleans.Streams.IAsyncObserver<T> observer, Orleans.Streams.StreamSequenceToken token, Orleans.Streams.StreamFilterPredicate filterFunc = default, object filterData = default);abstract member SubscribeAsync : Orleans.Streams.IAsyncObserver<'T> * Orleans.Streams.StreamSequenceToken * Orleans.Streams.StreamFilterPredicate * obj -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>>Public Function SubscribeAsync (observer As IAsyncObserver(Of T), token As StreamSequenceToken, Optional filterFunc As StreamFilterPredicate = Nothing, Optional filterData As Object = Nothing) As Task(Of StreamSubscriptionHandle(Of T))Paramètres
- observer
- IAsyncObserver<T>
Observateur asynchrone à abonner.
- 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 filterFunc pour prendre la décision de filtrage.
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.
Exceptions
Levée si la fonction de filtre de flux fournie ne convient pas. En règle générale, cela est dû au fait qu’il ne s’agit pas d’une méthode statique.