IAsyncStream<T> Interfaccia

Definizione

Spazio dei nomi:

Orleans.Streams

Assembly:

Orleans.Streaming.dll

Pacchetto:

Microsoft.Orleans.Streaming v8.2.0

Questa interfaccia rappresenta un oggetto che funge da rendezvous distribuito tra producer e consumer. È simile a un framework Subject reattivo e implementa IObserver né IObservable interfacce.

public interface IAsyncStream<T> : IComparable<Orleans.Streams.IAsyncStream<T>>, IEquatable<Orleans.Streams.IAsyncStream<T>>, Orleans.Streams.IAsyncBatchObservable<T>, Orleans.Streams.IAsyncBatchProducer<T>, Orleans.Streams.IAsyncObservable<T>, Orleans.Streams.IAsyncObserver<T>, Orleans.Streams.IAsyncStream

type IAsyncStream<'T> = interface
    interface IAsyncStream
    interface IEquatable<IAsyncStream<'T>>
    interface IComparable<IAsyncStream<'T>>
    interface IAsyncObservable<'T>
    interface IAsyncBatchObservable<'T>
    interface IAsyncBatchProducer<'T>
    interface IAsyncObserver<'T>

Public Interface IAsyncStream(Of T)
Implements IAsyncBatchObservable(Of T), IAsyncBatchProducer(Of T), IAsyncObservable(Of T), IAsyncObserver(Of T), IAsyncStream, IComparable(Of IAsyncStream(Of T)), IEquatable(Of IAsyncStream(Of T))

Parametri di tipo

T

Tipo di oggetto che scorre attraverso il flusso.

Implementazioni

IAsyncObservable<T> IAsyncObserver<T> IComparable<IAsyncStream<T>> IEquatable<IAsyncStream<T>> IAsyncBatchObservable<T> IAsyncBatchProducer<T> IAsyncStream

Proprietà

StreamId

Ottiene l'identificatore del flusso. (Ereditato da IAsyncStream)

Metodi

GetAllSubscriptionHandles()	Recupera un elenco di tutte le sottoscrizioni attive create dal chiamante per questo flusso.
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 da parte del consumer. (Ereditato da IAsyncObserver<T>)
OnErrorAsync(Exception)	Notifica al consumer che il flusso ha generato un errore. L'attività restituita da questo metodo deve essere completata al termine dell'elaborazione della chiusura del flusso da parte del consumer. (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 producer di un flusso, l'attività viene completata quando l'implementazione del flusso ha accettato la responsabilità dell'elemento e viene garantita la riunione delle garanzie di recapito. Ad esempio, un flusso basato su una coda durevole completerebbe l'attività quando l'elemento è stato salvato in modo permanente. Un flusso che offre il massimo sforzo una volta il recapito restituirà un'attività già completata. Quando il producer è 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 il recapito almeno una volta, 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. (Ereditato da IAsyncBatchProducer<T>)
SubscribeAsync(IAsyncBatchObserver<T>, StreamSequenceToken)	Sottoscrivere un consumer a questo batch osservabile. (Ereditato da IAsyncBatchObservable<T>)
SubscribeAsync(IAsyncBatchObserver<T>)	Sottoscrivere un consumer a questo batch osservabile. (Ereditato da IAsyncBatchObservable<T>)
SubscribeAsync(IAsyncObserver<T>, StreamSequenceToken, String)	Sottoscrivere un consumer a questo oggetto osservabile. (Ereditato da IAsyncObservable<T>)
SubscribeAsync(IAsyncObserver<T>)	Sottoscrivere un consumer a questo oggetto osservabile. (Ereditato da IAsyncObservable<T>)

Metodi di estensione

SubscribeAsync<T>(IAsyncBatchObservable<T>, Func<IList<SequentialItem<T>>,Task>, Func<Exception,Task>, Func<Task>)	Sottoscrivere un consumer a questo oggetto osservabile usando i delegati. Questo metodo è un helper per IAsyncBatchObservable.SubscribeAsync che consente alla classe di sottoscrizione di inline i metodi del gestore anziché richiedere un'istanza di IAsyncBatchObserver.
SubscribeAsync<T>(IAsyncBatchObservable<T>, Func<IList<SequentialItem<T>>,Task>, Func<Exception,Task>)	Sottoscrivere un consumer a questo oggetto osservabile usando i delegati. Questo metodo è un helper per IAsyncBatchObservable.SubscribeAsync che consente alla classe di sottoscrizione di inline i metodi del gestore anziché richiedere un'istanza di IAsyncBatchObserver.
SubscribeAsync<T>(IAsyncBatchObservable<T>, Func<IList<SequentialItem<T>>,Task>, Func<Task>)	Sottoscrivere un consumer a questo oggetto osservabile usando i delegati. Questo metodo è un helper per IAsyncBatchObservable.SubscribeAsync che consente alla classe di sottoscrizione di inline i metodi del gestore anziché richiedere un'istanza di IAsyncBatchObserver.
SubscribeAsync<T>(IAsyncBatchObservable<T>, Func<IList<SequentialItem<T>>,Task>)	Sottoscrivere un consumer a questo oggetto osservabile usando i delegati. Questo metodo è un helper per IAsyncBatchObservable.SubscribeAsync che consente alla classe di sottoscrizione di inline i metodi del gestore anziché richiedere un'istanza di IAsyncBatchObserver.
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>, 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>, 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>)	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.
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>)	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.