IAsyncObservable<T> Schnittstelle

Definition

Namespace:

Orleans.Streams

Assembly:

Orleans.Streaming.dll

Paket:

Microsoft.Orleans.Streaming v8.2.0

Diese Schnittstelle generalisiert die standardmäßige .NET IObserveable-Schnittstelle, um die asynchrone Verwendung von Elementen zu ermöglichen. Asynchron bedeutet hier, dass der Consumer Elemente asynchron verarbeiten und die Elementvervollständigung an den Produzenten signalisieren kann, indem er den zurückgegebenen Task abschließt.

Beachten Sie, dass diese Schnittstelle von Item Consumern aufgerufen (verwendet) und von Artikelproduzenten implementiert wird. Dies bedeutet, dass der Producerendpunkt eines Streams diese Schnittstelle implementiert.

public interface IAsyncObservable<T>

type IAsyncObservable<'T> = interface

Public Interface IAsyncObservable(Of T)

Typparameter

T

Der Typ des vom Beobachtbaren erzeugten Objekts.

Abgeleitet

Orleans.Streams.IAsyncStream<T>

Methoden

SubscribeAsync(IAsyncObserver<T>)	Abonnieren Sie einen Consumer für diesen Beobachtbaren.
SubscribeAsync(IAsyncObserver<T>, StreamSequenceToken, String)	Abonnieren Sie einen Consumer für diesen Beobachtbaren.

Erweiterungsmethoden

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