IAsyncBatchProducer<T> Schnittstelle

Definition

Namespace:

Orleans.Streams

Assembly:

Orleans.Streaming.dll

Paket:

Microsoft.Orleans.Streaming v8.1.0

Diese Schnittstelle generalisiert die IAsyncObserver-Schnittstelle, um die Produktion von Batches von Elementen zu ermöglichen.

Beachten Sie, dass diese Schnittstelle von Artikelherstellern (verwendet) aufgerufen wird.

public interface IAsyncBatchProducer<T> : Orleans.Streams.IAsyncObserver<T>

type IAsyncBatchProducer<'T> = interface
    interface IAsyncObserver<'T>

Public Interface IAsyncBatchProducer(Of T)
Implements IAsyncObserver(Of T)

Typparameter

T

Der Vom Beobachter verbrauchte Objekttyp.

Abgeleitet

Orleans.Streams.IAsyncStream<T>

Implementiert

IAsyncObserver<T>

Methoden

OnCompletedAsync()	benachrichtigt den Verbraucher, dass der Datenstrom abgeschlossen wurde. Die von dieser Methode zurückgegebene Aufgabe sollte abgeschlossen werden, wenn der Verbraucher die Verarbeitung des Datenstroms abgeschlossen hat. (Geerbt von IAsyncObserver<T>)
OnErrorAsync(Exception)	benachrichtigt den Verbraucher, dass der Datenstrom einen Fehler hatte. Die von dieser Methode zurückgegebene Aufgabe sollte abgeschlossen werden, wenn der Verbraucher die Verarbeitung des Datenstroms abgeschlossen hat. (Geerbt von IAsyncObserver<T>)
OnNextAsync(T, StreamSequenceToken)	Übergibt das nächste Element an den Verbraucher. Die von dieser Methode zurückgegebene Aufgabe sollte abgeschlossen werden, wenn die Verarbeitung des Artikels vom Verbraucher ausreichend verarbeitet wurde, um Verhaltensgarantien 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 sichergestellt ist, dass seine Liefergarantien erfüllt werden. Beispielsweise würde ein Datenstrom basierend auf einer dauerhaften Warteschlange den Vorgang abschließen, wenn das Element dauerhaft gespeichert wurde. Ein Datenstrom, der höchstens einmal den Aufwand bietet, würde eine Aufgabe zurückgeben, die bereits abgeschlossen ist. Wenn der Hersteller der (Verbraucherendpunkt) eines Datenstroms ist, sollte der Vorgang vom Verbrauchercode abgeschlossen werden, wenn er die Verantwortung für das Element übernommen hat. Insbesondere, wenn der Streamanbieter mindestens einmal die Lieferung garantiert, sollte der Artikel erst dann als geliefert betrachtet werden, wenn der vom Verbraucher zurückgegebene Vorgang abgeschlossen wurde. (Geerbt von IAsyncObserver<T>)
OnNextBatchAsync(IEnumerable<T>, StreamSequenceToken)	Übergibt den nächsten Stapel von Elementen an den Verbraucher. Die von dieser Methode zurückgegebene Aufgabe sollte abgeschlossen werden, wenn alle Elemente im Batch vom Verbraucher ausreichend verarbeitet wurden, um Verhaltensgarantien zu erfüllen. Dies heißt, die Semantik des zurückgegebenen Vorgangs entspricht dem OnNextAsync(T, StreamSequenceToken)für alle Elemente im Batch erweitert.