AsyncBatchObservableExtensions.SubscribeAsync Methode

Definition

Namespace:

Orleans.Streams

Assembly:

Orleans.Streaming.dll

Paket:

Microsoft.Orleans.Streaming v8.2.0

Überlädt

SubscribeAsync<T>(IAsyncBatchObservable<T>, Func<IList<SequentialItem<T>>,Task>)	Abonnieren sie einen Verbraucher mit Stellvertretungen. Diese Methode ist ein Hilfsprogramm für die IAsyncBatchObservable.SubscribeAsync, mit der die abonnierende Klasse die Methoden des Handlers inline 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 mit Stellvertretungen. Diese Methode ist ein Hilfsprogramm für die IAsyncBatchObservable.SubscribeAsync, mit der die abonnierende Klasse die Methoden des Handlers inline 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 mit Stellvertretungen. Diese Methode ist ein Hilfsprogramm für die IAsyncBatchObservable.SubscribeAsync, mit der die abonnierende Klasse die Methoden des Handlers inline 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 mit Stellvertretungen. Diese Methode ist ein Hilfsprogramm für die IAsyncBatchObservable.SubscribeAsync, mit der die abonnierende Klasse die Methoden des Handlers inline ermöglicht, anstatt eine Instanz von IAsyncBatchObserver zu benötigen.

SubscribeAsync<T>(IAsyncBatchObservable<T>, Func<IList<SequentialItem<T>>,Task>)

Abonnieren sie einen Verbraucher mit Stellvertretungen. Diese Methode ist ein Hilfsprogramm für die IAsyncBatchObservable.SubscribeAsync, mit der die abonnierende Klasse die Methoden des Handlers inline ermöglicht, anstatt eine Instanz von IAsyncBatchObserver zu benötigen.

public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T> (this Orleans.Streams.IAsyncBatchObservable<T> obs, Func<System.Collections.Generic.IList<Orleans.Streams.SequentialItem<T>>,System.Threading.Tasks.Task> onNextAsync);

static member SubscribeAsync : Orleans.Streams.IAsyncBatchObservable<'T> * Func<System.Collections.Generic.IList<Orleans.Streams.SequentialItem<'T>>, System.Threading.Tasks.Task> -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>>

<Extension()>
Public Function SubscribeAsync(Of T) (obs As IAsyncBatchObservable(Of T), onNextAsync As Func(Of IList(Of SequentialItem(Of T)), Task)) As Task(Of StreamSubscriptionHandle(Of T))

Typparameter

T

Der Vom beobachteten Objekttyp erzeugte Objekttyp.

Parameter

obs

IAsyncBatchObservable<T>

Das Observable-Objekt.

onNextAsync

Func<IList<SequentialItem<T>>,Task>

Stellvertretung, die für IAsyncBatchObserver.OnNextAsync aufgerufen wird.

Gibt zurück

Task<StreamSubscriptionHandle<T>>

Ein Versprechen für ein StreamSubscriptionHandle, das das Abonnement darstellt. Der Verbraucher kann sich mit diesem Handle abmelden. Das Abonnement bleibt so lange aktiv, solange es nicht explizit abgemeldet wird.

SubscribeAsync<T>(IAsyncBatchObservable<T>, Func<IList<SequentialItem<T>>,Task>, Func<Exception,Task>)

Abonnieren sie einen Verbraucher mit Stellvertretungen. Diese Methode ist ein Hilfsprogramm für die IAsyncBatchObservable.SubscribeAsync, mit der die abonnierende Klasse die Methoden des Handlers inline ermöglicht, anstatt eine Instanz von IAsyncBatchObserver zu benötigen.

public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T> (this Orleans.Streams.IAsyncBatchObservable<T> obs, Func<System.Collections.Generic.IList<Orleans.Streams.SequentialItem<T>>,System.Threading.Tasks.Task> onNextAsync, Func<Exception,System.Threading.Tasks.Task> onErrorAsync);

static member SubscribeAsync : Orleans.Streams.IAsyncBatchObservable<'T> * Func<System.Collections.Generic.IList<Orleans.Streams.SequentialItem<'T>>, System.Threading.Tasks.Task> * Func<Exception, System.Threading.Tasks.Task> -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>>

<Extension()>
Public Function SubscribeAsync(Of T) (obs As IAsyncBatchObservable(Of T), onNextAsync As Func(Of IList(Of SequentialItem(Of T)), Task), onErrorAsync As Func(Of Exception, Task)) As Task(Of StreamSubscriptionHandle(Of T))

Typparameter

T

Der Vom beobachteten Objekttyp erzeugte Objekttyp.

Parameter

obs

IAsyncBatchObservable<T>

Das Observable-Objekt.

onNextAsync

Func<IList<SequentialItem<T>>,Task>

Stellvertretung, die für IAsyncBatchObserver.OnNextAsync aufgerufen wird.

onErrorAsync

Func<Exception,Task>

Stellvertretung, die für IAsyncBatchObserver.OnErrorAsync aufgerufen wird.

Gibt zurück

Task<StreamSubscriptionHandle<T>>

Ein Versprechen für ein StreamSubscriptionHandle, das das Abonnement darstellt. Der Verbraucher kann sich mit diesem Handle abmelden. Das Abonnement bleibt so lange aktiv, solange es nicht explizit abgemeldet wird.

SubscribeAsync<T>(IAsyncBatchObservable<T>, Func<IList<SequentialItem<T>>,Task>, Func<Task>)

Abonnieren sie einen Verbraucher mit Stellvertretungen. Diese Methode ist ein Hilfsprogramm für die IAsyncBatchObservable.SubscribeAsync, mit der die abonnierende Klasse die Methoden des Handlers inline ermöglicht, anstatt eine Instanz von IAsyncBatchObserver zu benötigen.

public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T> (this Orleans.Streams.IAsyncBatchObservable<T> obs, Func<System.Collections.Generic.IList<Orleans.Streams.SequentialItem<T>>,System.Threading.Tasks.Task> onNextAsync, Func<System.Threading.Tasks.Task> onCompletedAsync);

static member SubscribeAsync : Orleans.Streams.IAsyncBatchObservable<'T> * Func<System.Collections.Generic.IList<Orleans.Streams.SequentialItem<'T>>, System.Threading.Tasks.Task> * Func<System.Threading.Tasks.Task> -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>>

<Extension()>
Public Function SubscribeAsync(Of T) (obs As IAsyncBatchObservable(Of T), onNextAsync As Func(Of IList(Of SequentialItem(Of T)), Task), onCompletedAsync As Func(Of Task)) As Task(Of StreamSubscriptionHandle(Of T))

Typparameter

T

Der Vom beobachteten Objekttyp erzeugte Objekttyp.

Parameter

obs

IAsyncBatchObservable<T>

Das Observable-Objekt.

onNextAsync

Func<IList<SequentialItem<T>>,Task>

Stellvertretung, die für IAsyncBatchObserver.OnNextAsync aufgerufen wird.

onCompletedAsync

Func<Task>

Stellvertretung, die für IAsyncBatchObserver.OnCompletedAsync aufgerufen wird.

Gibt zurück

Task<StreamSubscriptionHandle<T>>

Ein Versprechen für ein StreamSubscriptionHandle, das das Abonnement darstellt. Der Verbraucher kann sich mit diesem Handle abmelden. Das Abonnement bleibt so lange aktiv, solange es nicht explizit abgemeldet wird.

SubscribeAsync<T>(IAsyncBatchObservable<T>, Func<IList<SequentialItem<T>>,Task>, Func<Exception,Task>, Func<Task>)

Abonnieren sie einen Verbraucher mit Stellvertretungen. Diese Methode ist ein Hilfsprogramm für die IAsyncBatchObservable.SubscribeAsync, mit der die abonnierende Klasse die Methoden des Handlers inline ermöglicht, anstatt eine Instanz von IAsyncBatchObserver zu benötigen.

public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> SubscribeAsync<T> (this Orleans.Streams.IAsyncBatchObservable<T> obs, Func<System.Collections.Generic.IList<Orleans.Streams.SequentialItem<T>>,System.Threading.Tasks.Task> onNextAsync, Func<Exception,System.Threading.Tasks.Task> onErrorAsync, Func<System.Threading.Tasks.Task> onCompletedAsync);

static member SubscribeAsync : Orleans.Streams.IAsyncBatchObservable<'T> * Func<System.Collections.Generic.IList<Orleans.Streams.SequentialItem<'T>>, System.Threading.Tasks.Task> * Func<Exception, System.Threading.Tasks.Task> * Func<System.Threading.Tasks.Task> -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>>

<Extension()>
Public Function SubscribeAsync(Of T) (obs As IAsyncBatchObservable(Of T), onNextAsync As Func(Of IList(Of SequentialItem(Of T)), Task), onErrorAsync As Func(Of Exception, Task), onCompletedAsync As Func(Of Task)) As Task(Of StreamSubscriptionHandle(Of T))

Typparameter

T

Der Vom beobachteten Objekttyp erzeugte Objekttyp.

Parameter

obs

IAsyncBatchObservable<T>

Das Observable-Objekt.

onNextAsync

Func<IList<SequentialItem<T>>,Task>

Stellvertretung, die für IAsyncBatchObserver.OnNextAsync aufgerufen wird.

onErrorAsync

Func<Exception,Task>

Stellvertretung, die für IAsyncBatchObserver.OnErrorAsync aufgerufen wird.

onCompletedAsync

Func<Task>

Stellvertretung, die für IAsyncBatchObserver.OnCompletedAsync aufgerufen wird.

Gibt zurück

Task<StreamSubscriptionHandle<T>>

Ein Versprechen für ein StreamSubscriptionHandle, das das Abonnement darstellt. Der Verbraucher kann sich mit diesem Handle abmelden. Das Abonnement bleibt so lange aktiv, solange es nicht explizit abgemeldet wird.