StreamSubscriptionHandleExtensions.ResumeAsync Método

Definición

Espacio de nombres:

Orleans.Streams

Ensamblado:

Orleans.Streaming.dll

Paquete:

Microsoft.Orleans.Streaming v8.2.0

Sobrecargas

ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<IList<SequentialItem<T>>,Task>, StreamSequenceToken)	Se produce si la función de filtro de flujo proporcionada no es adecuada. Normalmente, esto se debe a que no es un método estático.
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<T,StreamSequenceToken,Task>, StreamSequenceToken)	Se produce si la función de filtro de flujo proporcionada no es adecuada. Normalmente, esto se debe a que no es un método estático.
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<IList<SequentialItem<T>>,Task>, Func<Exception,Task>, StreamSequenceToken)	Reanuda el consumo de una secuencia mediante delegados. Este método es un asistente para streamSubscriptionHandle.ResumeAsync que permite que la clase de suscripción inserte los métodos de controlador en lugar de requerir una instancia de IAsyncBatchObserver.
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<IList<SequentialItem<T>>,Task>, Func<Task>, StreamSequenceToken)	Reanuda el consumo de una secuencia mediante delegados. Este método es un asistente para streamSubscriptionHandle.ResumeAsync que permite que la clase de suscripción inserte los métodos de controlador en lugar de requerir una instancia de IAsyncBatchObserver.
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, StreamSequenceToken)	Reanuda el consumo de una secuencia mediante delegados. Este método es un asistente para streamSubscriptionHandle.ResumeAsync que permite que la clase de suscripción inserte los métodos de controlador en lugar de requerir una instancia de IAsyncObserver.
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<T,StreamSequenceToken,Task>, Func<Task>, StreamSequenceToken)	Reanuda el consumo de una secuencia mediante delegados. Este método es un asistente para streamSubscriptionHandle.ResumeAsync que permite que la clase de suscripción inserte los métodos de controlador en lugar de requerir una instancia de IAsyncObserver.
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<IList<SequentialItem<T>>,Task>, Func<Exception,Task>, Func<Task>, StreamSequenceToken)	Reanuda el consumo de una secuencia mediante delegados. Este método es un asistente para streamSubscriptionHandle.ResumeAsync que permite que la clase de suscripción inserte los métodos de controlador en lugar de requerir una instancia de IAsyncBatchObserver.
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, Func<Task>, StreamSequenceToken)	Reanuda el consumo de una secuencia mediante delegados. Este método es un asistente para streamSubscriptionHandle.ResumeAsync que permite que la clase de suscripción inserte los métodos de controlador en lugar de requerir una instancia de IAsyncObserver.

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

Se produce si la función de filtro de flujo proporcionada no es adecuada. Normalmente, esto se debe a que no es un método estático.

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

Parámetros de tipo

T

Tipo de objeto generado por el observable.

Parámetros

handle

StreamSubscriptionHandle<T>

Identificador de suscripción.

onNextAsync

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

Delegado al que se llama para IAsyncObserver.OnNextAsync.

token

StreamSequenceToken

Secuencia de secuencia desde la que se va a usar como desplazamiento para iniciar la suscripción.

Devoluciones

Task<StreamSubscriptionHandle<T>>

Promesa de streamSubscriptionHandle que representa la suscripción. El consumidor puede cancelar la suscripción mediante este identificador. La suscripción permanece activa siempre que no se cancele explícitamente.

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

Se produce si la función de filtro de flujo proporcionada no es adecuada. Normalmente, esto se debe a que no es un método estático.

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

Parámetros de tipo

T

Tipo de objeto generado por el observable.

Parámetros

handle

StreamSubscriptionHandle<T>

Identificador de suscripción.

onNextAsync

Func<T,StreamSequenceToken,Task>

Delegado al que se llama para IAsyncObserver.OnNextAsync.

token

StreamSequenceToken

Secuencia de secuencia desde la que se va a usar como desplazamiento para iniciar la suscripción.

Devoluciones

Task<StreamSubscriptionHandle<T>>

Promesa de streamSubscriptionHandle que representa la suscripción. El consumidor puede cancelar la suscripción mediante este identificador. La suscripción permanece activa siempre que no se cancele explícitamente.

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

Reanuda el consumo de una secuencia mediante delegados. Este método es un asistente para streamSubscriptionHandle.ResumeAsync que permite que la clase de suscripción inserte los métodos de controlador en lugar de requerir una instancia de IAsyncBatchObserver.

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

Parámetros de tipo

T

Tipo de objeto generado por el observable.

Parámetros

handle

StreamSubscriptionHandle<T>

Identificador de suscripción.

onNextAsync

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

Delegado al que se llama para IAsyncObserver.OnNextAsync.

onErrorAsync

Func<Exception,Task>

Delegado al que se llama para IAsyncObserver.OnErrorAsync.

token

StreamSequenceToken

Secuencia de secuencia desde la que se va a usar como desplazamiento para iniciar la suscripción.

Devoluciones

Task<StreamSubscriptionHandle<T>>

Promesa de streamSubscriptionHandle que representa la suscripción. El consumidor puede cancelar la suscripción mediante este identificador. La suscripción permanece activa siempre que no se cancele explícitamente.

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

Reanuda el consumo de una secuencia mediante delegados. Este método es un asistente para streamSubscriptionHandle.ResumeAsync que permite que la clase de suscripción inserte los métodos de controlador en lugar de requerir una instancia de IAsyncBatchObserver.

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

Parámetros de tipo

T

Tipo de objeto generado por el observable.

Parámetros

handle

StreamSubscriptionHandle<T>

Identificador de suscripción.

onNextAsync

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

Delegado al que se llama para IAsyncObserver.OnNextAsync.

onCompletedAsync

Func<Task>

Delegado al que se llama para IAsyncObserver.OnCompletedAsync.

token

StreamSequenceToken

Secuencia de secuencia desde la que se va a usar como desplazamiento para iniciar la suscripción.

Devoluciones

Task<StreamSubscriptionHandle<T>>

Promesa de streamSubscriptionHandle que representa la suscripción. El consumidor puede cancelar la suscripción mediante este identificador. La suscripción permanece activa siempre que no se cancele explícitamente.

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

Reanuda el consumo de una secuencia mediante delegados. Este método es un asistente para streamSubscriptionHandle.ResumeAsync que permite que la clase de suscripción inserte los métodos de controlador en lugar de requerir una instancia de IAsyncObserver.

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

Parámetros de tipo

T

Tipo de objeto generado por el observable.

Parámetros

handle

StreamSubscriptionHandle<T>

Identificador de suscripción.

onNextAsync

Func<T,StreamSequenceToken,Task>

Delegado al que se llama para IAsyncObserver.OnNextAsync.

onErrorAsync

Func<Exception,Task>

Delegado al que se llama para IAsyncObserver.OnErrorAsync.

token

StreamSequenceToken

Secuencia de secuencia desde la que se va a usar como desplazamiento para iniciar la suscripción.

Devoluciones

Task<StreamSubscriptionHandle<T>>

Promesa de streamSubscriptionHandle que representa la suscripción. El consumidor puede cancelar la suscripción mediante este identificador. La suscripción permanece activa siempre que no se cancele explícitamente.

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

Reanuda el consumo de una secuencia mediante delegados. Este método es un asistente para streamSubscriptionHandle.ResumeAsync que permite que la clase de suscripción inserte los métodos de controlador en lugar de requerir una instancia de IAsyncObserver.

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

Parámetros de tipo

T

Tipo de objeto generado por el observable.

Parámetros

handle

StreamSubscriptionHandle<T>

Identificador de suscripción.

onNextAsync

Func<T,StreamSequenceToken,Task>

Delegado al que se llama para IAsyncObserver.OnNextAsync.

onCompletedAsync

Func<Task>

Delegado al que se llama para IAsyncObserver.OnCompletedAsync.

token

StreamSequenceToken

Secuencia de secuencia desde la que se va a usar como desplazamiento para iniciar la suscripción.

Devoluciones

Task<StreamSubscriptionHandle<T>>

Promesa de streamSubscriptionHandle que representa la suscripción. El consumidor puede cancelar la suscripción mediante este identificador. La suscripción permanece activa siempre que no se cancele explícitamente.

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

Reanuda el consumo de una secuencia mediante delegados. Este método es un asistente para streamSubscriptionHandle.ResumeAsync que permite que la clase de suscripción inserte los métodos de controlador en lugar de requerir una instancia de IAsyncBatchObserver.

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

Parámetros de tipo

T

Tipo de objeto generado por el observable.

Parámetros

handle

StreamSubscriptionHandle<T>

Identificador de suscripción.

onNextAsync

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

Delegado al que se llama para IAsyncObserver.OnNextAsync.

onErrorAsync

Func<Exception,Task>

Delegado al que se llama para IAsyncObserver.OnErrorAsync.

onCompletedAsync

Func<Task>

Delegado al que se llama para IAsyncObserver.OnCompletedAsync.

token

StreamSequenceToken

Secuencia de secuencia desde la que se va a usar como desplazamiento para iniciar la suscripción.

Devoluciones

Task<StreamSubscriptionHandle<T>>

Promesa de streamSubscriptionHandle que representa la suscripción. El consumidor puede cancelar la suscripción mediante este identificador. La suscripción permanece activa siempre que no se cancele explícitamente.

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

Reanuda el consumo de una secuencia mediante delegados. Este método es un asistente para streamSubscriptionHandle.ResumeAsync que permite que la clase de suscripción inserte los métodos de controlador en lugar de requerir una instancia de IAsyncObserver.

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

Parámetros de tipo

T

Tipo de objeto generado por el observable.

Parámetros

handle

StreamSubscriptionHandle<T>

Identificador de suscripción.

onNextAsync

Func<T,StreamSequenceToken,Task>

Delegado al que se llama para IAsyncObserver.OnNextAsync.

onErrorAsync

Func<Exception,Task>

Delegado al que se llama para IAsyncObserver.OnErrorAsync.

onCompletedAsync

Func<Task>

Delegado al que se llama para IAsyncObserver.OnCompletedAsync.

token

StreamSequenceToken

Secuencia de secuencia desde la que se va a usar como desplazamiento para iniciar la suscripción.

Devoluciones

Task<StreamSubscriptionHandle<T>>

Promesa de streamSubscriptionHandle que representa la suscripción. El consumidor puede cancelar la suscripción mediante este identificador. La suscripción permanece activa siempre que no se cancele explícitamente.