AsyncObservableExtensions.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<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>) |
Abonnieren Sie einen Consumer für diese beobachtbare Mithilfe von Delegaten. Diese Methode ist ein Hilfsprogramm für IAsyncObservable.SubscribeAsync, sodass die abonnierende Klasse die Handlermethoden inline einschließt, anstatt eine Instanz von IAsyncObserver zu benötigen. |
| SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, StreamSequenceToken) |
Abonnieren Sie einen Consumer für diese beobachtbare Mithilfe von Delegaten. Diese Methode ist ein Hilfsprogramm für IAsyncObservable.SubscribeAsync, sodass die abonnierende Klasse die Handlermethoden inline einschließt, anstatt eine Instanz von IAsyncObserver zu benötigen. |
| SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>) |
Abonnieren Sie einen Consumer für diese beobachtbare Mithilfe von Delegaten. Diese Methode ist ein Hilfsprogramm für IAsyncObservable.SubscribeAsync, sodass die abonnierende Klasse die Handlermethoden inline einschließt, anstatt eine Instanz von IAsyncObserver zu benötigen. |
| SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Task>) |
Abonnieren Sie einen Consumer für diese beobachtbare Mithilfe von Delegaten. Diese Methode ist ein Hilfsprogramm für IAsyncObservable.SubscribeAsync, sodass die abonnierende Klasse die Handlermethoden inline einschließt, anstatt eine Instanz von IAsyncObserver zu benötigen. |
| SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, StreamSequenceToken) |
Abonnieren Sie einen Consumer für diese beobachtbare Mithilfe von Delegaten. Diese Methode ist ein Hilfsprogramm für IAsyncObservable.SubscribeAsync, sodass die abonnierende Klasse die Handlermethoden inline einschließt, anstatt eine Instanz von IAsyncObserver zu benötigen. |
| SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, Func<Task>) |
Abonnieren Sie einen Consumer für diese beobachtbare Mithilfe von Delegaten. Diese Methode ist ein Hilfsprogramm für IAsyncObservable.SubscribeAsync, sodass die abonnierende Klasse die Handlermethoden inline einschließt, anstatt eine Instanz von IAsyncObserver zu benötigen. |
| SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Task>, StreamSequenceToken) |
Abonnieren Sie einen Consumer für diese beobachtbare Mithilfe von Delegaten. Diese Methode ist ein Hilfsprogramm für IAsyncObservable.SubscribeAsync, sodass die abonnierende Klasse die Handlermethoden inline einschließt, anstatt eine Instanz von IAsyncObserver zu benötigen. |
| SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, StreamSequenceToken, StreamFilterPredicate, Object) |
Abonnieren Sie einen Consumer für diese beobachtbare Mithilfe von Delegaten. Diese Methode ist ein Hilfsprogramm für IAsyncObservable.SubscribeAsync, sodass die abonnierende Klasse die Handlermethoden inline einschließt, anstatt eine Instanz von IAsyncObserver zu benötigen. |
| SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, Func<Task>, StreamSequenceToken) |
Abonnieren Sie einen Consumer für diese beobachtbare Mithilfe von Delegaten. Diese Methode ist ein Hilfsprogramm für IAsyncObservable.SubscribeAsync, sodass die abonnierende Klasse die Handlermethoden inline einschließt, anstatt eine Instanz von IAsyncObserver zu benötigen. |
| SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, StreamSequenceToken, StreamFilterPredicate, Object) |
Abonnieren Sie einen Consumer für diese beobachtbare Mithilfe von Delegaten. Diese Methode ist ein Hilfsprogramm für IAsyncObservable.SubscribeAsync, sodass die abonnierende Klasse die Handlermethoden inline einschließt, anstatt eine Instanz von IAsyncObserver zu benötigen. |
| SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Task>, StreamSequenceToken, StreamFilterPredicate, Object) |
Abonnieren Sie einen Consumer für diese beobachtbare Mithilfe von Delegaten. Diese Methode ist ein Hilfsprogramm für IAsyncObservable.SubscribeAsync, sodass die abonnierende Klasse die Handlermethoden inline einschließt, anstatt eine Instanz von IAsyncObserver zu benötigen. |
| SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken, Task>, Func<Exception,Task>, Func<Task>, StreamSequenceToken, StreamFilterPredicate, Object) |
Abonnieren Sie einen Consumer für diese beobachtbare Mithilfe von Delegaten. Diese Methode ist ein Hilfsprogramm für IAsyncObservable.SubscribeAsync, sodass die abonnierende Klasse die Handlermethoden inline einschließt, anstatt eine Instanz von IAsyncObserver zu benötigen. |
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>)
- Quelle:
- AsyncObservableExtensions.cs
Abonnieren Sie einen Consumer für diese beobachtbare Mithilfe von Delegaten. Diese Methode ist ein Hilfsprogramm für IAsyncObservable.SubscribeAsync, sodass die abonnierende Klasse die Handlermethoden inline einschließt, anstatt eine Instanz von IAsyncObserver zu benötigen.
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))Typparameter
- T
Der Typ des vom Beobachtbaren erzeugten Objekts.
Parameter
Das Observable-Objekt.
- onNextAsync
- Func<T,StreamSequenceToken,Task>
Delegat, der für IAsyncObserver.OnNextAsync aufgerufen 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<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, StreamSequenceToken)
Abonnieren Sie einen Consumer für diese beobachtbare Mithilfe von Delegaten. Diese Methode ist ein Hilfsprogramm für IAsyncObservable.SubscribeAsync, sodass die abonnierende Klasse die Handlermethoden inline einschließt, anstatt eine Instanz von IAsyncObserver zu benötigen.
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))Typparameter
- T
Der Typ des vom Beobachtbaren erzeugten Objekts.
Parameter
Das Observable-Objekt.
- onNextAsync
- Func<T,StreamSequenceToken,Task>
Delegat, der für IAsyncObserver.OnNextAsync aufgerufen wird.
- token
- StreamSequenceToken
Die Streamsequenz, die als Offset zum Starten des Abonnements verwendet 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.
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:
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>)
- Quelle:
- AsyncObservableExtensions.cs
Abonnieren Sie einen Consumer für diese beobachtbare Mithilfe von Delegaten. Diese Methode ist ein Hilfsprogramm für IAsyncObservable.SubscribeAsync, sodass die abonnierende Klasse die Handlermethoden inline einschließt, anstatt eine Instanz von IAsyncObserver zu benötigen.
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))Typparameter
- T
Der Typ des vom Beobachtbaren erzeugten Objekts.
Parameter
Das Observable-Objekt.
- onNextAsync
- Func<T,StreamSequenceToken,Task>
Delegat, der für IAsyncObserver.OnNextAsync aufgerufen 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<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Task>)
- Quelle:
- AsyncObservableExtensions.cs
Abonnieren Sie einen Consumer für diese beobachtbare Mithilfe von Delegaten. Diese Methode ist ein Hilfsprogramm für IAsyncObservable.SubscribeAsync, sodass die abonnierende Klasse die Handlermethoden inline einschließt, anstatt eine Instanz von IAsyncObserver zu benötigen.
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))Typparameter
- T
Der Typ des vom Beobachtbaren erzeugten Objekts.
Parameter
Das Observable-Objekt.
- onNextAsync
- Func<T,StreamSequenceToken,Task>
Delegat, der für IAsyncObserver.OnNextAsync aufgerufen 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<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, StreamSequenceToken)
Abonnieren Sie einen Consumer für diese beobachtbare Mithilfe von Delegaten. Diese Methode ist ein Hilfsprogramm für IAsyncObservable.SubscribeAsync, sodass die abonnierende Klasse die Handlermethoden inline einschließt, anstatt eine Instanz von IAsyncObserver zu benötigen.
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))Typparameter
- T
Der Typ des vom Beobachtbaren erzeugten Objekts.
Parameter
Das Observable-Objekt.
- onNextAsync
- Func<T,StreamSequenceToken,Task>
Delegat, der für IAsyncObserver.OnNextAsync aufgerufen wird.
- token
- StreamSequenceToken
Die Streamsequenz, die als Offset zum Starten des Abonnements verwendet 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.
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:
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, Func<Task>)
- Quelle:
- AsyncObservableExtensions.cs
Abonnieren Sie einen Consumer für dieses Beobachtbare mithilfe von Delegaten. Diese Methode ist ein Hilfsprogramm für IAsyncObservable.SubscribeAsync, sodass die abonnierende Klasse die Handlermethoden inlinen kann, anstatt eine Instanz von IAsyncObserver zu benötigen.
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))Typparameter
- T
Der Typ des Objekts, das vom beobachtbaren erzeugt wird.
Parameter
Das Observable-Objekt.
- onNextAsync
- Func<T,StreamSequenceToken,Task>
Delegat, der für IAsyncObserver.OnNextAsync aufgerufen wird.
Gibt zurück
Eine Zusage für ein StreamSubscriptionHandle, das das Abonnement darstellt. Der Consumer kann sich mit diesem Handle abmelden. Das Abonnement bleibt so lange aktiv, wie es nicht explizit abbestellt wird.
Gilt für:
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Task>, StreamSequenceToken)
Abonnieren Sie einen Consumer für dieses Beobachtbare mithilfe von Delegaten. Diese Methode ist ein Hilfsprogramm für IAsyncObservable.SubscribeAsync, sodass die abonnierende Klasse die Handlermethoden inlinen kann, anstatt eine Instanz von IAsyncObserver zu benötigen.
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))Typparameter
- T
Der Typ des Objekts, das vom beobachtbaren erzeugt wird.
Parameter
Das Observable-Objekt.
- onNextAsync
- Func<T,StreamSequenceToken,Task>
Delegat, der für IAsyncObserver.OnNextAsync aufgerufen wird.
- token
- StreamSequenceToken
Die Streamsequenz, die als Offset zum Starten des Abonnements verwendet werden soll.
Gibt zurück
Eine Zusage für ein StreamSubscriptionHandle, das das Abonnement darstellt. Der Consumer kann sich mit diesem Handle abmelden. Das Abonnement bleibt so lange aktiv, wie es nicht explizit abbestellt 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:
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, StreamSequenceToken, StreamFilterPredicate, Object)
- Quelle:
- AsyncObservableExtensions.cs
Abonnieren Sie einen Consumer für dieses Beobachtbare mithilfe von Delegaten. Diese Methode ist ein Hilfsprogramm für IAsyncObservable.SubscribeAsync, sodass die abonnierende Klasse die Handlermethoden inlinen kann, anstatt eine Instanz von IAsyncObserver zu benötigen.
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))Typparameter
- T
Der Typ des Objekts, das vom beobachtbaren erzeugt wird.
Parameter
Das Observable-Objekt.
- onNextAsync
- Func<T,StreamSequenceToken,Task>
Delegte, die für IAsyncObserver.OnNextAsync aufgerufen wird.
- 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 in der Regel alle Paramater, die von filterFunc benötigt werden, um die Filterentscheidung zu treffen.
Gibt zurück
Eine Zusage für ein StreamSubscriptionHandle, das das Abonnement darstellt. Der Consumer kann sich mit diesem Handle abmelden. Das Abonnement bleibt so lange aktiv, wie es nicht explizit abbestellt 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:
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, Func<Task>, StreamSequenceToken)
Abonnieren Sie einen Consumer für dieses Beobachtbare mithilfe von Delegaten. Diese Methode ist ein Hilfsprogramm für IAsyncObservable.SubscribeAsync, sodass die abonnierende Klasse die Handlermethoden inlinen kann, anstatt eine Instanz von IAsyncObserver zu benötigen.
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))Typparameter
- T
Der Typ des Objekts, das vom beobachtbaren erzeugt wird.
Parameter
Das Observable-Objekt.
- onNextAsync
- Func<T,StreamSequenceToken,Task>
Delegat, der für IAsyncObserver.OnNextAsync aufgerufen wird.
- token
- StreamSequenceToken
Die Streamsequenz, die als Offset zum Starten des Abonnements verwendet werden soll.
Gibt zurück
Eine Zusage für ein StreamSubscriptionHandle, das das Abonnement darstellt. Der Consumer kann sich mit diesem Handle abmelden. Das Abonnement bleibt so lange aktiv, wie es nicht explizit abbestellt 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:
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, StreamSequenceToken, StreamFilterPredicate, Object)
- Quelle:
- AsyncObservableExtensions.cs
Abonnieren Sie einen Consumer für dieses Beobachtbare mithilfe von Delegaten. Diese Methode ist ein Hilfsprogramm für IAsyncObservable.SubscribeAsync, sodass die abonnierende Klasse die Handlermethoden inlinen kann, anstatt eine Instanz von IAsyncObserver zu benötigen.
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))Typparameter
- T
Der Typ des Objekts, das vom beobachtbaren erzeugt wird.
Parameter
Das Observable-Objekt.
- onNextAsync
- Func<T,StreamSequenceToken,Task>
Delegte, die für IAsyncObserver.OnNextAsync aufgerufen wird.
- 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 in der Regel alle Paramater, die von filterFunc benötigt werden, um die Filterentscheidung zu treffen.
Gibt zurück
Eine Zusage für ein StreamSubscriptionHandle, das das Abonnement darstellt. Der Consumer kann sich mit diesem Handle abmelden. Das Abonnement bleibt so lange aktiv, wie es nicht explizit abbestellt 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:
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Task>, StreamSequenceToken, StreamFilterPredicate, Object)
- Quelle:
- AsyncObservableExtensions.cs
Abonnieren Sie einen Consumer für dieses Beobachtbare mithilfe von Delegaten. Diese Methode ist ein Hilfsprogramm für IAsyncObservable.SubscribeAsync, sodass die abonnierende Klasse die Handlermethoden inlinen kann, anstatt eine Instanz von IAsyncObserver zu benötigen.
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))Typparameter
- T
Der Typ des Objekts, das vom beobachtbaren erzeugt wird.
Parameter
Das Observable-Objekt.
- onNextAsync
- Func<T,StreamSequenceToken,Task>
Delegte, die für IAsyncObserver.OnNextAsync aufgerufen wird.
- 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 in der Regel alle Paramater, die von filterFunc benötigt werden, um die Filterentscheidung zu treffen.
Gibt zurück
Eine Zusage für ein StreamSubscriptionHandle, das das Abonnement darstellt. Der Consumer kann sich mit diesem Handle abmelden. Das Abonnement bleibt so lange aktiv, wie es nicht explizit abbestellt 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:
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken, Task>, Func<Exception,Task>, Func<Task>, StreamSequenceToken, StreamFilterPredicate, Object)
- Quelle:
- AsyncObservableExtensions.cs
Abonnieren Sie einen Consumer für dieses Beobachtbare mithilfe von Delegaten. Diese Methode ist ein Hilfsprogramm für IAsyncObservable.SubscribeAsync, sodass die abonnierende Klasse die Handlermethoden inlinen kann, anstatt eine Instanz von IAsyncObserver zu benötigen.
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))Typparameter
- T
Der Typ des Objekts, das vom beobachtbaren erzeugt wird.
Parameter
Das Observable-Objekt.
- onNextAsync
- Func<T,StreamSequenceToken,Task>
Delegte, die für IAsyncObserver.OnNextAsync aufgerufen wird.
- 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 in der Regel alle Paramater, die von filterFunc benötigt werden, um die Filterentscheidung zu treffen.
Gibt zurück
Eine Zusage für ein StreamSubscriptionHandle, das das Abonnement darstellt. Der Consumer kann sich mit diesem Handle abmelden. Das Abonnement bleibt so lange aktiv, wie es nicht explizit abbestellt 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.