IAsyncObserver<T>.OnNextAsync(T, StreamSequenceToken) Methode

Definition

Namespace:

Orleans.Streams

Assembly:

Orleans.Streaming.dll

Paket:

Microsoft.Orleans.Streaming v8.2.0

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

public System.Threading.Tasks.Task OnNextAsync (T item, Orleans.Streams.StreamSequenceToken? token = default);

abstract member OnNextAsync : 'T * Orleans.Streams.StreamSequenceToken -> System.Threading.Tasks.Task

Public Function OnNextAsync (item As T, Optional token As StreamSequenceToken = Nothing) As Task

Parameter

item

T

Das Element, das übergeben werden soll.

token

StreamSequenceToken

Das Datenstromsequenztoken dieses Elements.

Gibt zurück

Task

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