IAsyncObservable<T>.SubscribeAsync Methode
Definition
Wichtig
Einige Informationen beziehen sich auf Vorabversionen, die vor dem Release ggf. grundlegend überarbeitet werden. Microsoft übernimmt hinsichtlich der hier bereitgestellten Informationen keine Gewährleistungen, seien sie ausdrücklich oder konkludent.
Überlädt
SubscribeAsync(IAsyncObserver<T>) |
Abonnieren Sie einen Consumer für diesen Beobachtbaren. |
SubscribeAsync(IAsyncObserver<T>, StreamSequenceToken, String) |
Abonnieren Sie einen Consumer für diesen Beobachtbaren. |
SubscribeAsync(IAsyncObserver<T>, StreamSequenceToken, StreamFilterPredicate, Object) |
Abonnieren Sie einen Consumer für diesen Beobachtbaren. |
SubscribeAsync(IAsyncObserver<T>)
- Quelle:
- IAsyncObservable.cs
Abonnieren Sie einen Consumer für diesen Beobachtbaren.
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))
Parameter
- observer
- IAsyncObserver<T>
Der asynchrone Beobachter, der abonniert werden soll.
Gibt zurück
Eine Zusage für ein StreamSubscriptionHandle, das das Abonnement darstellt. Der Verbraucher kann sich mit diesem Handle abmelden. Das Abonnement bleibt aktiv, solange es nicht explizit abbestellt wird.
Gilt für:
SubscribeAsync(IAsyncObserver<T>, StreamSequenceToken, String)
Abonnieren Sie einen Consumer für diesen Beobachtbaren.
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))
Parameter
- observer
- IAsyncObserver<T>
Der asynchrone Beobachter, der abonniert werden soll.
- token
- StreamSequenceToken
Die Streamsequenz, die als Offset zum Starten des Abonnements verwendet werden soll.
- filterData
- String
Datenobjekt, das an den Filter übergeben wird.
Gibt zurück
Eine Zusage für ein StreamSubscriptionHandle, das das Abonnement darstellt. Der Verbraucher kann sich mit diesem Handle abmelden. Das Abonnement bleibt aktiv, solange es nicht explizit abbestellt wird.
Gilt für:
SubscribeAsync(IAsyncObserver<T>, StreamSequenceToken, StreamFilterPredicate, Object)
- Quelle:
- IAsyncObservable.cs
Abonnieren Sie einen Consumer für diesen Beobachtbaren.
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))
Parameter
- observer
- IAsyncObserver<T>
Der asynchrone Beobachter, der abonniert werden soll.
- token
- StreamSequenceToken
Die Streamsequenz, die als Offset zum Starten des Abonnements verwendet werden soll.
- filterFunc
- StreamFilterPredicate
Filter, der für dieses Abonnement angewendet werden soll
- filterData
- Object
Datenobjekt, das an filterFunc übergeben wird. Dies enthält normalerweise alle Parameter, die von filterFunc erforderlich sind, um die Filterentscheidung zu treffen.
Gibt zurück
Eine Zusage für ein StreamSubscriptionHandle, das das Abonnement darstellt. Der Verbraucher kann sich mit diesem Handle abmelden. Das Abonnement bleibt solange aktiv, wie es nicht explizit abgemeldet wird.
Ausnahmen
Wird ausgelöst, wenn die bereitgestellte Streamfilterfunktion nicht geeignet ist. In der Regel liegt dies daran, dass es sich nicht um eine statische Methode handelt.