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

Definizione

Spazio dei nomi:

Orleans.Streams

Assembly:

Orleans.Streaming.dll

Pacchetto:

Microsoft.Orleans.Streaming v8.2.0

Passa l'elemento successivo al consumer.

L'attività restituita da questo metodo deve essere completata quando l'elaborazione dell'elemento è stata sufficientemente elaborata dal consumer per soddisfare eventuali garanzie comportamentali.

Quando il consumer è l'endpoint del produttore di un flusso, l'attività viene completata quando l'implementazione del flusso ha accettato la responsabilità per l'elemento e viene assicurata di soddisfare le garanzie di recapito. Ad esempio, un flusso basato su una coda durevole completa l'attività quando l'elemento è stato salvato in modo permanente. Un flusso che fornisce il massimo sforzo una volta che il recapito restituirà un'attività già completata.

Quando il produttore è l'endpoint consumer di un flusso, l'attività deve essere completata dal codice consumer quando ha accettato la responsabilità dell'elemento. In particolare, se il provider di flusso garantisce almeno una volta il recapito, l'elemento non deve essere considerato recapitato fino al completamento dell'attività restituita dal consumer.

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

Parametri

item

T

Elemento da passare.

token

StreamSequenceToken

Token della sequenza di flusso di questo elemento.

Restituisce

Task

Attività completata quando l'elemento è stato accettato.