IAsyncObserver<T> Interfaccia

Definizione

Spazio dei nomi:

Orleans.Streams

Assembly:

Orleans.Streaming.dll

Pacchetto:

Microsoft.Orleans.Streaming v8.2.0

Questa interfaccia generalizza l'interfaccia IObserver .NET standard per consentire la produzione asincrona di elementi.

Si noti che questa interfaccia viene implementata dai consumer di elementi e richiamata (utilizzata) dai produttori di elementi. Ciò significa che l'endpoint consumer di un flusso implementa questa interfaccia.

public interface IAsyncObserver<in T>

type IAsyncObserver<'T> = interface

Public Interface IAsyncObserver(Of In T)

Parametri di tipo

T

Tipo di oggetto utilizzato dall'osservatore.

Questo parametro di tipo è controvariante, ovvero puoi usare il tipo specificato o qualsiasi tipo meno derivato. Per altre informazioni sulla covarianza e la controvarianza, vedi Covarianza e controvarianza nei generics.

Derivato

Orleans.Streams.IAsyncBatchProducer<T>

Orleans.Streams.IAsyncStream<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.
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.
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.