StreamSubscriptionHandleExtensions.ResumeAsync Methode

Definition

Namespace:

Orleans.Streams

Assembly:

Orleans.Streaming.dll

Paket:

Microsoft.Orleans.Streaming v8.2.0

Überlädt

ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<IList<SequentialItem<T>>,Task>, StreamSequenceToken)	Wird ausgelöst, wenn die angegebene Streamfilterfunktion nicht geeignet ist. Dies liegt in der Regel daran, dass es sich nicht um eine statische Methode handelt.
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<T,StreamSequenceToken,Task>, StreamSequenceToken)	Wird ausgelöst, wenn die angegebene Streamfilterfunktion nicht geeignet ist. Dies liegt in der Regel daran, dass es sich nicht um eine statische Methode handelt.
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<IList<SequentialItem<T>>,Task>, Func<Exception,Task>, StreamSequenceToken)	Setzt den Verbrauch eines Datenstroms mithilfe von Stellvertretungen fort. Diese Methode ist ein Hilfsprogramm für streamSubscriptionHandle.ResumeAsync, mit dem die abonnierende Klasse inline die Handlermethoden angibt, anstatt eine Instanz von IAsyncBatchObserver zu benötigen.
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<IList<SequentialItem<T>>,Task>, Func<Task>, StreamSequenceToken)	Setzt den Verbrauch eines Datenstroms mithilfe von Stellvertretungen fort. Diese Methode ist ein Hilfsprogramm für streamSubscriptionHandle.ResumeAsync, mit dem die abonnierende Klasse inline die Handlermethoden angibt, anstatt eine Instanz von IAsyncBatchObserver zu benötigen.
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, StreamSequenceToken)	Setzt den Verbrauch eines Datenstroms mithilfe von Stellvertretungen fort. Diese Methode ist ein Hilfsprogramm für die StreamSubscriptionHandle.ResumeAsync, mit der die abonnierende Klasse inline die Handlermethoden inline ausgeführt werden kann, anstatt eine Instanz von IAsyncObserver zu benötigen.
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<T,StreamSequenceToken,Task>, Func<Task>, StreamSequenceToken)	Setzt den Verbrauch eines Datenstroms mithilfe von Stellvertretungen fort. Diese Methode ist ein Hilfsprogramm für die StreamSubscriptionHandle.ResumeAsync, mit der die abonnierende Klasse inline die Handlermethoden inline ausgeführt werden kann, anstatt eine Instanz von IAsyncObserver zu benötigen.
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<IList<SequentialItem<T>>,Task>, Func<Exception,Task>, Func<Task>, StreamSequenceToken)	Setzt den Verbrauch eines Datenstroms mithilfe von Stellvertretungen fort. Diese Methode ist ein Hilfsprogramm für streamSubscriptionHandle.ResumeAsync, mit dem die abonnierende Klasse inline die Handlermethoden angibt, anstatt eine Instanz von IAsyncBatchObserver zu benötigen.
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, Func<Task>, StreamSequenceToken)	Setzt den Verbrauch eines Datenstroms mithilfe von Stellvertretungen fort. Diese Methode ist ein Hilfsprogramm für die StreamSubscriptionHandle.ResumeAsync, mit der die abonnierende Klasse inline die Handlermethoden inline ausgeführt werden kann, anstatt eine Instanz von IAsyncObserver zu benötigen.

ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<IList<SequentialItem<T>>,Task>, StreamSequenceToken)

Wird ausgelöst, wenn die angegebene Streamfilterfunktion nicht geeignet ist. Dies liegt in der Regel daran, dass es sich nicht um eine statische Methode handelt.

public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> ResumeAsync<T> (this Orleans.Streams.StreamSubscriptionHandle<T> handle, Func<System.Collections.Generic.IList<Orleans.Streams.SequentialItem<T>>,System.Threading.Tasks.Task> onNextAsync, Orleans.Streams.StreamSequenceToken token = default);

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

<Extension()>
Public Function ResumeAsync(Of T) (handle As StreamSubscriptionHandle(Of T), onNextAsync As Func(Of IList(Of SequentialItem(Of T)), Task), Optional token As StreamSequenceToken = Nothing) As Task(Of StreamSubscriptionHandle(Of T))

Typparameter

T

Der Typ des Objekts, das von der Observable erzeugt wird.

Parameter

handle

StreamSubscriptionHandle<T>

Das Abonnementhandle.

onNextAsync

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

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

token

StreamSequenceToken

Die Streamsequenz, die als Offset verwendet werden soll, um das Abonnement zu starten.

Gibt zurück

Task<StreamSubscriptionHandle<T>>

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

ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<T,StreamSequenceToken,Task>, StreamSequenceToken)

Wird ausgelöst, wenn die angegebene Streamfilterfunktion nicht geeignet ist. Dies liegt in der Regel daran, dass es sich nicht um eine statische Methode handelt.

public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> ResumeAsync<T> (this Orleans.Streams.StreamSubscriptionHandle<T> handle, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync, Orleans.Streams.StreamSequenceToken token = default);

static member ResumeAsync : Orleans.Streams.StreamSubscriptionHandle<'T> * Func<'T, Orleans.Streams.StreamSequenceToken, System.Threading.Tasks.Task> * Orleans.Streams.StreamSequenceToken -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>>

<Extension()>
Public Function ResumeAsync(Of T) (handle As StreamSubscriptionHandle(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task), Optional token As StreamSequenceToken = Nothing) As Task(Of StreamSubscriptionHandle(Of T))

Typparameter

T

Der Typ des Objekts, das von der Observable erzeugt wird.

Parameter

handle

StreamSubscriptionHandle<T>

Das Abonnementhandle.

onNextAsync

Func<T,StreamSequenceToken,Task>

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

token

StreamSequenceToken

Die Streamsequenz, die als Offset verwendet werden soll, um das Abonnement zu starten.

Gibt zurück

Task<StreamSubscriptionHandle<T>>

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

ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<IList<SequentialItem<T>>,Task>, Func<Exception,Task>, StreamSequenceToken)

Setzt den Verbrauch eines Datenstroms mithilfe von Stellvertretungen fort. Diese Methode ist ein Hilfsprogramm für streamSubscriptionHandle.ResumeAsync, mit dem die abonnierende Klasse inline die Handlermethoden angibt, anstatt eine Instanz von IAsyncBatchObserver zu benötigen.

public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> ResumeAsync<T> (this Orleans.Streams.StreamSubscriptionHandle<T> handle, Func<System.Collections.Generic.IList<Orleans.Streams.SequentialItem<T>>,System.Threading.Tasks.Task> onNextAsync, Func<Exception,System.Threading.Tasks.Task> onErrorAsync, Orleans.Streams.StreamSequenceToken token = default);

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

<Extension()>
Public Function ResumeAsync(Of T) (handle As StreamSubscriptionHandle(Of T), onNextAsync As Func(Of IList(Of SequentialItem(Of T)), Task), onErrorAsync As Func(Of Exception, Task), Optional token As StreamSequenceToken = Nothing) As Task(Of StreamSubscriptionHandle(Of T))

Typparameter

T

Der Typ des Objekts, das von der Observable erzeugt wird.

Parameter

handle

StreamSubscriptionHandle<T>

Das Abonnementhandle.

onNextAsync

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

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

onErrorAsync

Func<Exception,Task>

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

token

StreamSequenceToken

Die Streamsequenz, die als Offset verwendet werden soll, um das Abonnement zu starten.

Gibt zurück

Task<StreamSubscriptionHandle<T>>

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

ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<IList<SequentialItem<T>>,Task>, Func<Task>, StreamSequenceToken)

Setzt den Verbrauch eines Datenstroms mithilfe von Stellvertretungen fort. Diese Methode ist ein Hilfsprogramm für streamSubscriptionHandle.ResumeAsync, mit dem die abonnierende Klasse inline die Handlermethoden angibt, anstatt eine Instanz von IAsyncBatchObserver zu benötigen.

public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> ResumeAsync<T> (this Orleans.Streams.StreamSubscriptionHandle<T> handle, Func<System.Collections.Generic.IList<Orleans.Streams.SequentialItem<T>>,System.Threading.Tasks.Task> onNextAsync, Func<System.Threading.Tasks.Task> onCompletedAsync, Orleans.Streams.StreamSequenceToken token = default);

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

<Extension()>
Public Function ResumeAsync(Of T) (handle As StreamSubscriptionHandle(Of T), onNextAsync As Func(Of IList(Of SequentialItem(Of T)), Task), onCompletedAsync As Func(Of Task), Optional token As StreamSequenceToken = Nothing) As Task(Of StreamSubscriptionHandle(Of T))

Typparameter

T

Der Typ des Objekts, das von der Observable erzeugt wird.

Parameter

handle

StreamSubscriptionHandle<T>

Das Abonnementhandle.

onNextAsync

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

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

onCompletedAsync

Func<Task>

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

token

StreamSequenceToken

Die Streamsequenz, die als Offset verwendet werden soll, um das Abonnement zu starten.

Gibt zurück

Task<StreamSubscriptionHandle<T>>

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

ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, StreamSequenceToken)

Setzt den Verbrauch eines Datenstroms mithilfe von Stellvertretungen fort. Diese Methode ist ein Hilfsprogramm für die StreamSubscriptionHandle.ResumeAsync, mit der die abonnierende Klasse inline die Handlermethoden inline ausgeführt werden kann, anstatt eine Instanz von IAsyncObserver zu benötigen.

public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> ResumeAsync<T> (this Orleans.Streams.StreamSubscriptionHandle<T> handle, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync, Func<Exception,System.Threading.Tasks.Task> onErrorAsync, Orleans.Streams.StreamSequenceToken token = default);

static member ResumeAsync : Orleans.Streams.StreamSubscriptionHandle<'T> * Func<'T, Orleans.Streams.StreamSequenceToken, System.Threading.Tasks.Task> * Func<Exception, System.Threading.Tasks.Task> * Orleans.Streams.StreamSequenceToken -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>>

<Extension()>
Public Function ResumeAsync(Of T) (handle As StreamSubscriptionHandle(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task), onErrorAsync As Func(Of Exception, Task), Optional token As StreamSequenceToken = Nothing) As Task(Of StreamSubscriptionHandle(Of T))

Typparameter

T

Der Typ des Objekts, das von der Observable erzeugt wird.

Parameter

handle

StreamSubscriptionHandle<T>

Das Abonnementhandle.

onNextAsync

Func<T,StreamSequenceToken,Task>

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

onErrorAsync

Func<Exception,Task>

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

token

StreamSequenceToken

Die Streamsequenz, die als Offset verwendet werden soll, um das Abonnement zu starten.

Gibt zurück

Task<StreamSubscriptionHandle<T>>

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

ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<T,StreamSequenceToken,Task>, Func<Task>, StreamSequenceToken)

Setzt den Verbrauch eines Datenstroms mithilfe von Stellvertretungen fort. Diese Methode ist ein Hilfsprogramm für die StreamSubscriptionHandle.ResumeAsync, mit der die abonnierende Klasse inline die Handlermethoden inline ausgeführt werden kann, anstatt eine Instanz von IAsyncObserver zu benötigen.

public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> ResumeAsync<T> (this Orleans.Streams.StreamSubscriptionHandle<T> handle, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync, Func<System.Threading.Tasks.Task> onCompletedAsync, Orleans.Streams.StreamSequenceToken token = default);

static member ResumeAsync : Orleans.Streams.StreamSubscriptionHandle<'T> * Func<'T, Orleans.Streams.StreamSequenceToken, System.Threading.Tasks.Task> * Func<System.Threading.Tasks.Task> * Orleans.Streams.StreamSequenceToken -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>>

<Extension()>
Public Function ResumeAsync(Of T) (handle As StreamSubscriptionHandle(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task), onCompletedAsync As Func(Of Task), Optional token As StreamSequenceToken = Nothing) As Task(Of StreamSubscriptionHandle(Of T))

Typparameter

T

Der Typ des Objekts, das von der Observable erzeugt wird.

Parameter

handle

StreamSubscriptionHandle<T>

Das Abonnementhandle.

onNextAsync

Func<T,StreamSequenceToken,Task>

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

onCompletedAsync

Func<Task>

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

token

StreamSequenceToken

Die Streamsequenz, die als Offset verwendet werden soll, um das Abonnement zu starten.

Gibt zurück

Task<StreamSubscriptionHandle<T>>

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

ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<IList<SequentialItem<T>>,Task>, Func<Exception,Task>, Func<Task>, StreamSequenceToken)

Setzt den Verbrauch eines Datenstroms mithilfe von Stellvertretungen fort. Diese Methode ist ein Hilfsprogramm für streamSubscriptionHandle.ResumeAsync, mit dem die abonnierende Klasse inline die Handlermethoden angibt, anstatt eine Instanz von IAsyncBatchObserver zu benötigen.

public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> ResumeAsync<T> (this Orleans.Streams.StreamSubscriptionHandle<T> handle, 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, Orleans.Streams.StreamSequenceToken token = default);

static member ResumeAsync : Orleans.Streams.StreamSubscriptionHandle<'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> * Orleans.Streams.StreamSequenceToken -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>>

<Extension()>
Public Function ResumeAsync(Of T) (handle As StreamSubscriptionHandle(Of T), onNextAsync As Func(Of IList(Of SequentialItem(Of T)), Task), onErrorAsync As Func(Of Exception, Task), onCompletedAsync As Func(Of Task), Optional token As StreamSequenceToken = Nothing) As Task(Of StreamSubscriptionHandle(Of T))

Typparameter

T

Der Vom beobachteten Objekttyp erzeugte Objekttyp.

Parameter

handle

StreamSubscriptionHandle<T>

Das Abonnementhandle.

onNextAsync

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

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

onErrorAsync

Func<Exception,Task>

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

onCompletedAsync

Func<Task>

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

token

StreamSequenceToken

Die Streamsequenz, die als Offset verwendet werden soll, um das Abonnement zu starten.

Gibt zurück

Task<StreamSubscriptionHandle<T>>

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

ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, Func<Task>, StreamSequenceToken)

Fortgesetzt den Verbrauch eines Datenstroms mithilfe von Stellvertretungen. Diese Methode ist ein Hilfsprogramm für die StreamSubscriptionHandle.ResumeAsync, mit der die Abonnementklasse die Methoden des Handlers inline angibt, anstatt eine Instanz von IAsyncObserver zu benötigen.

public static System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<T>> ResumeAsync<T> (this Orleans.Streams.StreamSubscriptionHandle<T> handle, Func<T,Orleans.Streams.StreamSequenceToken,System.Threading.Tasks.Task> onNextAsync, Func<Exception,System.Threading.Tasks.Task> onErrorAsync, Func<System.Threading.Tasks.Task> onCompletedAsync, Orleans.Streams.StreamSequenceToken token = default);

static member ResumeAsync : Orleans.Streams.StreamSubscriptionHandle<'T> * Func<'T, Orleans.Streams.StreamSequenceToken, System.Threading.Tasks.Task> * Func<Exception, System.Threading.Tasks.Task> * Func<System.Threading.Tasks.Task> * Orleans.Streams.StreamSequenceToken -> System.Threading.Tasks.Task<Orleans.Streams.StreamSubscriptionHandle<'T>>

<Extension()>
Public Function ResumeAsync(Of T) (handle As StreamSubscriptionHandle(Of T), onNextAsync As Func(Of T, StreamSequenceToken, Task), onErrorAsync As Func(Of Exception, Task), onCompletedAsync As Func(Of Task), Optional token As StreamSequenceToken = Nothing) As Task(Of StreamSubscriptionHandle(Of T))

Typparameter

T

Der Vom beobachteten Objekttyp erzeugte Objekttyp.

Parameter

handle

StreamSubscriptionHandle<T>

Der Abonnementhandpunkt.

onNextAsync

Func<T,StreamSequenceToken,Task>

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

onErrorAsync

Func<Exception,Task>

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

onCompletedAsync

Func<Task>

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

token

StreamSequenceToken

Die Streamsequenz, die als Offset verwendet werden soll, um das Abonnement zu starten.

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.