IAsyncObservable<T> Interfaccia

Definizione

Spazio dei nomi:

Orleans.Streams

Assembly:

Orleans.Streaming.dll

Pacchetto:

Microsoft.Orleans.Streaming v8.2.0

Questa interfaccia generalizza l'interfaccia IObserveable standard per consentire l'utilizzo asincrono di elementi. In questo modo, il consumer può elaborare gli elementi in modo asincrono e segnalare il completamento dell'elemento al produttore completando l'attività restituita.

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

public interface IAsyncObservable<T>

type IAsyncObservable<'T> = interface

Public Interface IAsyncObservable(Of T)

Parametri di tipo

T

Tipo di oggetto prodotto dall'osservabile.

Derivato

Orleans.Streams.IAsyncStream<T>

Metodi

SubscribeAsync(IAsyncObserver<T>)	Sottoscrivere un consumer a questo oggetto osservabile.
SubscribeAsync(IAsyncObserver<T>, StreamSequenceToken, String)	Sottoscrivere un consumer a questo oggetto osservabile.

Metodi di estensione

SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>)	Sottoscrivere un consumer a questo oggetto osservabile usando i delegati. Questo metodo è un helper per IAsyncObservable.SubscribeAsync che consente alla classe di sottoscrizione di inline i metodi del gestore anziché richiedere un'istanza di IAsyncObserver.
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, StreamSequenceToken)	Sottoscrivere un consumer a questo oggetto osservabile usando i delegati. Questo metodo è un helper per IAsyncObservable.SubscribeAsync che consente alla classe di sottoscrizione di inline i metodi del gestore anziché richiedere un'istanza di IAsyncObserver.
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>)	Sottoscrivere un consumer a questo oggetto osservabile usando i delegati. Questo metodo è un helper per IAsyncObservable.SubscribeAsync che consente alla classe di sottoscrizione di inline i metodi del gestore anziché richiedere un'istanza di IAsyncObserver.
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, StreamSequenceToken)	Sottoscrivere un consumer a questo oggetto osservabile usando i delegati. Questo metodo è un helper per IAsyncObservable.SubscribeAsync che consente alla classe di sottoscrizione di inline i metodi del gestore anziché richiedere un'istanza di IAsyncObserver.
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, Func<Task>)	Sottoscrivere un consumer a questo oggetto osservabile usando i delegati. Questo metodo è un helper per IAsyncObservable.SubscribeAsync che consente alla classe di sottoscrizione di inline i metodi del gestore anziché richiedere un'istanza di IAsyncObserver.
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, Func<Task>, StreamSequenceToken)	Sottoscrivere un consumer a questo oggetto osservabile usando i delegati. Questo metodo è un helper per IAsyncObservable.SubscribeAsync che consente alla classe di sottoscrizione di inline i metodi del gestore anziché richiedere un'istanza di IAsyncObserver.
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Task>)	Sottoscrivere un consumer a questo oggetto osservabile usando i delegati. Questo metodo è un helper per IAsyncObservable.SubscribeAsync che consente alla classe di sottoscrizione di inline i metodi del gestore anziché richiedere un'istanza di IAsyncObserver.
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Task>, StreamSequenceToken)	Sottoscrivere un consumer a questo oggetto osservabile usando i delegati. Questo metodo è un helper per IAsyncObservable.SubscribeAsync che consente alla classe di sottoscrizione di inline i metodi del gestore anziché richiedere un'istanza di IAsyncObserver.