IAsyncBatchObservable<T> Schnittstelle

Referenz

Definition

Namespace:: Orleans.Streams

Assembly:: Orleans.Core.Abstractions.dll

Assembly:: Orleans.Streaming.dll

Paket:: Microsoft.Orleans.Core.Abstractions v2.4.5

Paket:: Microsoft.Orleans.Core.Abstractions v3.6.5

Paket:: Microsoft.Orleans.Streaming v7.2.5

Paket:: Microsoft.Orleans.Streaming v8.0.0

Paket:: Microsoft.Orleans.Streaming v8.1.0

Paket:: Microsoft.Orleans.Streaming v8.2.0

Quelle:: IAsyncBatchObservable.cs

Wichtig

Einige Informationen beziehen sich auf Vorabversionen, die vor dem Release ggf. grundlegend überarbeitet werden. Microsoft übernimmt hinsichtlich der hier bereitgestellten Informationen keine Gewährleistungen, seien sie ausdrücklich oder konkludent.

Diese Schnittstelle generalisiert die IAsyncObserver-Schnittstelle, um die Produktion und den Verbrauch von Batches von Elementen zu ermöglichen.

Beachten Sie, dass diese Schnittstelle von Elementkonsumenten implementiert und von Artikelherstellern aufgerufen (verwendet) wird. Dies bedeutet, dass der Consumerendpunkt eines Datenstroms diese Schnittstelle implementiert.

public interface IAsyncBatchObservable<T>

type IAsyncBatchObservable<'T> = interface

Public Interface IAsyncBatchObservable(Of T)

Typparameter

T

Der Vom Beobachter verbrauchte Objekttyp.

Abgeleitet: Orleans.Streams.IAsyncStream<T>

Methoden

SubscribeAsync(IAsyncBatchObserver<T>)	Abonnieren Sie einen Verbraucher für diesen Batch, der beobachtet werden kann.
SubscribeAsync(IAsyncBatchObserver<T>, StreamSequenceToken)	Abonnieren Sie einen Verbraucher für diesen Batch, der beobachtet werden kann.

Erweiterungsmethoden

SubscribeAsync<T>(IAsyncBatchObservable<T>, Func<IList<SequentialItem<T>>,Task>)	Abonnieren Sie einen Verbraucher für diese beobachtbare Verwendung von Stellvertretungen. Diese Methode ist eine Hilfsmethode für die IAsyncBatchObservable.SubscribeAsync, die die abonnierende Klasse inline der Handlermethoden ermöglicht, anstatt eine Instanz von IAsyncBatchObserver zu benötigen.
SubscribeAsync<T>(IAsyncBatchObservable<T>, Func<IList<SequentialItem<T>>,Task>, Func<Exception,Task>)	Abonnieren Sie einen Verbraucher für diese beobachtbare Verwendung von Stellvertretungen. Diese Methode ist eine Hilfsmethode für die IAsyncBatchObservable.SubscribeAsync, die die abonnierende Klasse inline der Handlermethoden ermöglicht, 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 Verbraucher für diese beobachtbare Verwendung von Stellvertretungen. Diese Methode ist eine Hilfsmethode für die IAsyncBatchObservable.SubscribeAsync, die die abonnierende Klasse inline der Handlermethoden ermöglicht, anstatt eine Instanz von IAsyncBatchObserver zu benötigen.
SubscribeAsync<T>(IAsyncBatchObservable<T>, Func<IList<SequentialItem<T>>,Task>, Func<Task>)	Abonnieren Sie einen Verbraucher für diese beobachtbare Verwendung von Stellvertretungen. Diese Methode ist eine Hilfsmethode für die IAsyncBatchObservable.SubscribeAsync, die die abonnierende Klasse inline der Handlermethoden ermöglicht, anstatt eine Instanz von IAsyncBatchObserver zu benötigen.

Gilt für:

Freigeben über