IAsyncStream<T> Schnittstelle

Definition

Namespace:

Orleans.Streams

Assembly:

Orleans.Streaming.dll

Paket:

Microsoft.Orleans.Streaming v8.1.0

Diese Schnittstelle stellt ein Objekt dar, das als verteiltes Rendezvous zwischen Produzenten und Consumern dient. Es ähnelt einem reaktiven IObserver Framework Subject und implementiert keine IObservable Schnittstellen.

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))

Typparameter

T

Der Typ des Objekts, das den Stream durchläuft.

Implementiert

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

Eigenschaften

StreamId

Ruft den Streambezeichner ab. (Geerbt von IAsyncStream)

Methoden

GetAllSubscriptionHandles()	Ruft eine Liste aller aktiven Abonnements ab, die vom Aufrufer für diesen Stream erstellt wurden.
OnCompletedAsync()	Benachrichtigt den Consumer, dass der Stream abgeschlossen wurde. Der von dieser Methode zurückgegebene Task sollte abgeschlossen werden, wenn der Consumer mit der Verarbeitung des Stream-Verschlusses fertig ist. (Geerbt von IAsyncObserver<T>)
OnErrorAsync(Exception)	Benachrichtigt den Consumer, dass beim Stream ein Fehler aufgetreten ist. Der von dieser Methode zurückgegebene Task sollte abgeschlossen werden, wenn der Consumer mit der Verarbeitung des Stream-Verschlusses fertig ist. (Geerbt von IAsyncObserver<T>)
OnNextAsync(T, StreamSequenceToken)	Übergibt das nächste Element an den Consumer. Die von dieser Methode zurückgegebene Aufgabe sollte abgeschlossen werden, wenn die Verarbeitung des Artikels vom Verbraucher ausreichend verarbeitet wurde, um verhaltensbedingte Garantien zu erfüllen. Wenn der Consumer der (Producerendpunkt) eines Streams ist, wird die Aufgabe abgeschlossen, wenn die Streamimplementierung die Verantwortung für den Artikel übernommen hat und sichergestellt ist, dass die Übermittlungsgarantien erfüllt werden. Beispielsweise würde ein Stream, der auf einer dauerhaften Warteschlange basiert, die Aufgabe abschließen, wenn das Element dauerhaft gespeichert wurde. Ein Stream, der höchstens nach der Übermittlung best-effort bietet, würde eine Aufgabe zurückgeben, die bereits abgeschlossen ist. Wenn der Produzent der (Consumerendpunkt) eines Streams ist, sollte die Aufgabe vom Consumercode abgeschlossen werden, wenn er die Verantwortung für das Element übernommen hat. Insbesondere, wenn der Streamanbieter eine mindestens einmale Lieferung garantiert, sollte der Artikel erst als geliefert gelten, wenn die vom Verbraucher zurückgegebene Aufgabe abgeschlossen ist. (Geerbt von IAsyncObserver<T>)
OnNextBatchAsync(IEnumerable<T>, StreamSequenceToken)	Übergibt den nächsten Batch von Elementen an den Consumer. Die von dieser Methode zurückgegebene Aufgabe sollte abgeschlossen werden, wenn alle Elemente im Batch vom Verbraucher ausreichend verarbeitet wurden, um verhaltensbezogene Garantien zu erfüllen. Das heißt, die Semantik des zurückgegebenen Tasks ist identisch mit für OnNextAsync(T, StreamSequenceToken), erweitert für alle Elemente im Batch. (Geerbt von IAsyncBatchProducer<T>)
SubscribeAsync(IAsyncBatchObserver<T>)	Abonnieren Sie einen Consumer für diesen beobachtbaren Batch. (Geerbt von IAsyncBatchObservable<T>)
SubscribeAsync(IAsyncBatchObserver<T>, StreamSequenceToken)	Abonnieren Sie einen Consumer für diesen beobachtbaren Batch. (Geerbt von IAsyncBatchObservable<T>)
SubscribeAsync(IAsyncObserver<T>)	Abonnieren Sie einen Consumer für diesen Beobachtbaren. (Geerbt von IAsyncObservable<T>)
SubscribeAsync(IAsyncObserver<T>, StreamSequenceToken, String)	Abonnieren Sie einen Consumer für diesen Beobachtbaren. (Geerbt von IAsyncObservable<T>)

Erweiterungsmethoden

SubscribeAsync<T>(IAsyncBatchObservable<T>, Func<IList<SequentialItem<T>>,Task>)	Abonnieren Sie einen Consumer für diese beobachtbare Mithilfe von Delegaten. Diese Methode ist ein Hilfsprogramm für die IAsyncBatchObservable.SubscribeAsync, die es der abonnierenden Klasse ermöglicht, die Handlermethoden inline zu verwenden, anstatt eine Instanz von IAsyncBatchObserver zu benötigen.
SubscribeAsync<T>(IAsyncBatchObservable<T>, Func<IList<SequentialItem<T>>,Task>, Func<Exception,Task>)	Abonnieren Sie einen Consumer für diese beobachtbare Mithilfe von Delegaten. Diese Methode ist ein Hilfsprogramm für die IAsyncBatchObservable.SubscribeAsync, die es der abonnierenden Klasse ermöglicht, die Handlermethoden inline zu verwenden, anstatt eine Instanz von IAsyncBatchObserver zu benötigen.
SubscribeAsync<T>(IAsyncBatchObservable<T>, Func<IList<SequentialItem<T>>,Task>, Func<Exception,Task>, Func<Task>)	Abonnieren Sie einen Consumer für diese beobachtbare Mithilfe von Delegaten. Diese Methode ist ein Hilfsprogramm für die IAsyncBatchObservable.SubscribeAsync, die es der abonnierenden Klasse ermöglicht, die Handlermethoden inline zu verwenden, anstatt eine Instanz von IAsyncBatchObserver zu benötigen.
SubscribeAsync<T>(IAsyncBatchObservable<T>, Func<IList<SequentialItem<T>>,Task>, Func<Task>)	Abonnieren Sie einen Consumer für diese beobachtbare Mithilfe von Delegaten. Diese Methode ist ein Hilfsprogramm für die IAsyncBatchObservable.SubscribeAsync, die es der abonnierenden Klasse ermöglicht, die Handlermethoden inline zu verwenden, anstatt eine Instanz von IAsyncBatchObserver zu benötigen.
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>)	Abonnieren Sie einen Consumer für diese beobachtbare Mithilfe von Delegaten. Diese Methode ist ein Hilfsprogramm für IAsyncObservable.SubscribeAsync, sodass die abonnierende Klasse die Handlermethoden inline einschließt, anstatt eine Instanz von IAsyncObserver zu benötigen.
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, StreamSequenceToken)	Abonnieren Sie einen Consumer für diese beobachtbare Mithilfe von Delegaten. Diese Methode ist ein Hilfsprogramm für IAsyncObservable.SubscribeAsync, sodass die abonnierende Klasse die Handlermethoden inline einschließt, anstatt eine Instanz von IAsyncObserver zu benötigen.
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>)	Abonnieren Sie einen Consumer für diese beobachtbare Mithilfe von Delegaten. Diese Methode ist ein Hilfsprogramm für IAsyncObservable.SubscribeAsync, sodass die abonnierende Klasse die Handlermethoden inline einschließt, anstatt eine Instanz von IAsyncObserver zu benötigen.
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, StreamSequenceToken)	Abonnieren Sie einen Consumer für diese beobachtbare Mithilfe von Delegaten. Diese Methode ist ein Hilfsprogramm für IAsyncObservable.SubscribeAsync, sodass die abonnierende Klasse die Handlermethoden inline einschließt, anstatt eine Instanz von IAsyncObserver zu benötigen.
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, Func<Task>)	Abonnieren Sie einen Consumer für diese beobachtbare Mithilfe von Delegaten. Diese Methode ist ein Hilfsprogramm für IAsyncObservable.SubscribeAsync, sodass die abonnierende Klasse die Handlermethoden inline einschließt, anstatt eine Instanz von IAsyncObserver zu benötigen.
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, Func<Task>, StreamSequenceToken)	Abonnieren Sie einen Consumer für diese beobachtbare Mithilfe von Delegaten. Diese Methode ist ein Hilfsprogramm für IAsyncObservable.SubscribeAsync, sodass die abonnierende Klasse die Handlermethoden inline einschließt, anstatt eine Instanz von IAsyncObserver zu benötigen.
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Task>)	Abonnieren Sie einen Consumer für diese beobachtbare Mithilfe von Delegaten. Diese Methode ist ein Hilfsprogramm für IAsyncObservable.SubscribeAsync, sodass die abonnierende Klasse die Handlermethoden inline einschließt, anstatt eine Instanz von IAsyncObserver zu benötigen.
SubscribeAsync<T>(IAsyncObservable<T>, Func<T,StreamSequenceToken,Task>, Func<Task>, StreamSequenceToken)	Abonnieren Sie einen Consumer für diese beobachtbare Mithilfe von Delegaten. Diese Methode ist ein Hilfsprogramm für IAsyncObservable.SubscribeAsync, sodass die abonnierende Klasse die Handlermethoden inline einschließt, anstatt eine Instanz von IAsyncObserver zu benötigen.