Freigeben über


IAsyncObservable<T>.SubscribeAsync Methode

Definition

Ü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.

Gilt für: