IAsyncObserver<T> Schnittstelle

Definition

Namespace:

Orleans.Streams

Assembly:

Orleans.Streaming.dll

Paket:

Microsoft.Orleans.Streaming v8.2.0

Diese Schnittstelle generalisiert die standardmäßige .NET IObserver-Schnittstelle, um die asynchrone Produktion von Elementen zu ermöglichen.

Beachten Sie, dass diese Schnittstelle von Elementverbrauchern implementiert und von Elementhersteller aufgerufen (verwendet) wird. Dies bedeutet, dass der Verbraucherendpunkt eines Datenstroms diese Schnittstelle implementiert.

public interface IAsyncObserver<in T>

type IAsyncObserver<'T> = interface

Public Interface IAsyncObserver(Of In T)

Typparameter

T

Der Vom Beobachter verbrauchte Objekttyp.

Dieser Typparameter ist kontravariant. Das bedeutet, dass Sie entweder den angegebenen Typ oder einen weniger abgeleiteten Typ verwenden können. Weitere Informationen zu Kovarianz und Kontravarianz finden Sie unter Kovarianz und Kontravarianz in Generics.

Abgeleitet

Orleans.Streams.IAsyncBatchProducer<T>

Orleans.Streams.IAsyncStream<T>

Methoden

OnCompletedAsync()	Benachrichtigt den Verbraucher, dass der Datenstrom abgeschlossen wurde. Der vorgang, der aus dieser Methode zurückgegeben wird, sollte abgeschlossen werden, wenn der Verbraucher die Verarbeitung der Datenstromschließung abgeschlossen hat.
OnErrorAsync(Exception)	Benachrichtigt den Verbraucher, dass der Datenstrom einen Fehler hatte. Der vorgang, der aus dieser Methode zurückgegeben wird, sollte abgeschlossen werden, wenn der Verbraucher die Verarbeitung der Datenstromschließung abgeschlossen hat.
OnNextAsync(T, StreamSequenceToken)	Übergibt das nächste Element an den Verbraucher. Der von dieser Methode zurückgegebene Vorgang sollte abgeschlossen werden, wenn die Verarbeitung des Elements vom Verbraucher ausreichend verarbeitet wurde, um verhaltensbezogene Garantien zu erfüllen. Wenn der Verbraucher der (Herstellerendpunkt) eines Datenstroms ist, wird der Vorgang abgeschlossen, wenn die Streamimplementierung die Verantwortung für das Element übernommen hat und seine Übermittlungsgarantien erfüllt. Beispielsweise würde ein Datenstrom basierend auf einer dauerhaften Warteschlange den Vorgang abschließen, wenn das Element dauerhaft gespeichert wurde. Ein Datenstrom, der am häufigsten eine Aufgabe zurückgibt, die bereits abgeschlossen ist. Wenn der Hersteller der (Verbraucherendpunkt) eines Datenstroms ist, sollte der Vorgang durch den Verbrauchercode abgeschlossen werden, wenn er die Verantwortung für das Element akzeptiert hat. Wenn der Streamanbieter die Lieferung mindestens einmal garantiert, sollte der Artikel erst als geliefert werden, wenn der vom Verbraucher zurückgegebene Vorgang abgeschlossen wurde.