IAsyncStream<T> Interfaccia
Definizione
Importante
Alcune informazioni sono relative alla release non definitiva del prodotto, che potrebbe subire modifiche significative prima della release definitiva. Microsoft non riconosce alcuna garanzia, espressa o implicita, in merito alle informazioni qui fornite.
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.IAsyncBatchObserver<T>, Orleans.Streams.IAsyncObservable<T>, Orleans.Streams.IAsyncObserver<T>, Orleans.Streams.IStreamIdentity
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.IStreamIdentity
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 IStreamIdentity
interface IEquatable<IAsyncStream<'T>>
interface IComparable<IAsyncStream<'T>>
interface IAsyncObservable<'T>
interface IAsyncBatchObserver<'T>
interface IAsyncObserver<'T>
type IAsyncStream<'T> = interface
interface IStreamIdentity
interface IEquatable<IAsyncStream<'T>>
interface IComparable<IAsyncStream<'T>>
interface IAsyncObservable<'T>
interface IAsyncBatchObservable<'T>
interface IAsyncBatchProducer<'T>
interface IAsyncObserver<'T>
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 IAsyncBatchObserver(Of T), IAsyncObservable(Of T), IAsyncObserver(Of T), IComparable(Of IAsyncStream(Of T)), IEquatable(Of IAsyncStream(Of T)), IStreamIdentity
Public Interface IAsyncStream(Of T)
Implements IAsyncBatchObservable(Of T), IAsyncBatchProducer(Of T), IAsyncObservable(Of T), IAsyncObserver(Of T), IComparable(Of IAsyncStream(Of T)), IEquatable(Of IAsyncStream(Of T)), IStreamIdentity
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
Proprietà
Guid |
Ottiene l'identificatore univoco. (Ereditato da IStreamIdentity) |
IsRewindable |
Determina se si tratta di un flusso riavvolgibile: supporta la sottoscrizione dal momento precedente. |
Namespace |
Ottiene lo spazio dei nomi. (Ereditato da IStreamIdentity) |
ProviderName |
Nome provider di flusso. |
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(IList<SequentialItem<T>>) |
Passa il batch successivo di elementi al consumer. L'attività restituita da questo metodo deve essere completata quando l'elaborazione degli elementi è 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à per gli elementi e viene garantita la riunione delle garanzie di recapito. Ad esempio, un flusso basato su una coda durevole completerebbe l'attività quando gli elementi sono stati salvati 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à per gli elementi. In particolare, se il provider di flusso garantisce il recapito at-least-once, gli elementi non devono essere considerati recapitati fino al completamento dell'attività restituita dal consumer. (Ereditato da IAsyncBatchObserver<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>) |
Sottoscrivere un consumer a questo batch osservabile. (Ereditato da IAsyncBatchObservable<T>) |
SubscribeAsync(IAsyncBatchObserver<T>, StreamSequenceToken) |
Sottoscrivere un consumer a questo batch osservabile. (Ereditato da IAsyncBatchObservable<T>) |
SubscribeAsync(IAsyncObserver<T>) |
Sottoscrivere un consumer a questo oggetto osservabile. (Ereditato da IAsyncObservable<T>) |
SubscribeAsync(IAsyncObserver<T>, StreamSequenceToken, StreamFilterPredicate, Object) |
Sottoscrivere un consumer a questo oggetto osservabile. (Ereditato da IAsyncObservable<T>) |
SubscribeAsync(IAsyncObserver<T>, StreamSequenceToken, String) |
Sottoscrivere un consumer a questo oggetto osservabile. (Ereditato da IAsyncObservable<T>) |
Metodi di estensione
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>(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<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<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>) |
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>, StreamSequenceToken, StreamFilterPredicate, Object) |
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>, StreamSequenceToken, StreamFilterPredicate, Object) |
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<Exception,Task>, Func<Task>, StreamSequenceToken, StreamFilterPredicate, Object) |
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. |
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Task>, StreamSequenceToken, StreamFilterPredicate, Object) |
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. |