IAsyncBatchObserver<T>.OnNextAsync Methode

Definition

Namespace:

Orleans.Streams

Assembly:

Orleans.Streaming.dll

Paket:

Microsoft.Orleans.Streaming v8.2.0

Übergibt den nächsten Stapel von Elementen an den Verbraucher.

Die von dieser Methode zurückgegebene Aufgabe sollte abgeschlossen werden, wenn die Verarbeitung der Elemente 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 die Elemente ü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 die Elemente dauerhaft gespeichert wurden. 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 die Elemente übernommen hat. Insbesondere, wenn der Streamanbieter mindestens einmal die Lieferung garantiert, sollte die Ware erst dann als geliefert betrachtet werden, wenn der vom Verbraucher zurückgegebene Vorgang abgeschlossen wurde.

public System.Threading.Tasks.Task OnNextAsync (System.Collections.Generic.IList<Orleans.Streams.SequentialItem<T>> items);

abstract member OnNextAsync : System.Collections.Generic.IList<Orleans.Streams.SequentialItem<'T>> -> System.Threading.Tasks.Task

Public Function OnNextAsync (items As IList(Of SequentialItem(Of T))) As Task

Parameter

items

IList<SequentialItem<T>>

Das Element, das übergeben werden soll.

Gibt zurück

Task

Eine Aufgabe, die abgeschlossen ist, wenn das Element akzeptiert wurde.