IAsyncBatchProducer<T> Interfaccia

Definizione

Spazio dei nomi:

Orleans.Streams

Assembly:

Orleans.Streaming.dll

Pacchetto:

Microsoft.Orleans.Streaming v8.2.0

Questa interfaccia generalizza l'interfaccia IAsyncObserver per consentire l'produzione di batch di elementi.

Si noti che questa interfaccia viene richiamata (utilizzata) dai produttori di elementi.

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

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

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

Parametri di tipo

T

Tipo di oggetto utilizzato dall'osservatore.

Derivato

Orleans.Streams.IAsyncStream<T>

Implementazioni

IAsyncObserver<T>

Metodi

OnCompletedAsync()	Notifica al consumer che il flusso è stato completato. L'attività restituita da questo metodo deve essere completata al termine dell'elaborazione della chiusura del flusso. (Ereditato da IAsyncObserver<T>)
OnErrorAsync(Exception)	Notifica al consumer che il flusso ha avuto un errore. L'attività restituita da questo metodo deve essere completata al termine dell'elaborazione della chiusura del flusso. (Ereditato da IAsyncObserver<T>)
OnNextAsync(T, StreamSequenceToken)	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. (Ereditato da IAsyncObserver<T>)
OnNextBatchAsync(IEnumerable<T>, StreamSequenceToken)	Passa il batch successivo di elementi al consumer. L'attività restituita da questo metodo deve essere completata quando tutti gli elementi del batch sono stati sufficientemente elaborati dal consumer per soddisfare eventuali garanzie comportamentali. Vale a dire, la semantica dell'attività restituita è uguale a per OnNextAsync(T, StreamSequenceToken), estesa per tutti gli elementi del batch.