IAsyncBatchObserver<T> Schnittstelle
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.
Diese Schnittstelle generalisiert die IAsyncObserver-Schnittstelle, um die Produktion und den Verbrauch von Batches 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 IAsyncBatchObserver<in T> : Orleans.Streams.IAsyncObserver<in T>public interface IAsyncBatchObserver<T>type IAsyncBatchObserver<'T> = interface
interface IAsyncObserver<'T>type IAsyncBatchObserver<'T> = interfacePublic Interface IAsyncBatchObserver(Of In T)
Implements IAsyncObserver(Of In T)Public Interface IAsyncBatchObserver(Of 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
- Implementiert
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(IList<SequentialItem<T>>) |
Übergibt den nächsten Batch von Elementen an den Verbraucher. Der von dieser Methode zurückgegebene Vorgang sollte abgeschlossen werden, wenn die Verarbeitung der Elemente durch den 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 die Elemente übernommen hat und seine Übermittlungsgarantien erfüllt. Beispielsweise würde ein Datenstrom basierend auf einer dauerhaften Warteschlange den Vorgang abschließen, wenn die Elemente dauerhaft gespeichert wurden. 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 die Elemente akzeptiert hat. Wenn der Streamanbieter die Lieferung mindestens einmal garantiert, sollten die Elemente erst als geliefert werden, wenn der vom Verbraucher zurückgegebene Vorgang abgeschlossen wurde. |
| 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. (Geerbt von IAsyncObserver<T>) |
| OnNextBatchAsync(IEnumerable<T>, StreamSequenceToken) |
Übergibt den nächsten Batch von Elementen an den Verbraucher. Der von dieser Methode zurückgegebene Vorgang sollte abgeschlossen werden, wenn alle Elemente im Batch ausreichend von dem Verbraucher verarbeitet wurden, um Verhaltensgarantien zu erfüllen.
Das heißt, die Semantik des zurückgegebenen Vorgangs entspricht |