StreamSubscriptionHandleExtensions.ResumeAsync Metodo

Definizione

Spazio dei nomi:

Orleans.Streams

Assembly:

Orleans.Streaming.dll

Pacchetto:

Microsoft.Orleans.Streaming v8.2.0

Overload

ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<IList<SequentialItem<T>>,Task>, StreamSequenceToken)	Generata se la funzione di filtro del flusso fornita non è adatta. In genere ciò è dovuto al fatto che non è un metodo statico.
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<T,StreamSequenceToken,Task>, StreamSequenceToken)	Generata se la funzione di filtro del flusso fornita non è adatta. In genere ciò è dovuto al fatto che non è un metodo statico.
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<IList<SequentialItem<T>>,Task>, Func<Exception,Task>, StreamSequenceToken)	Riprende l'utilizzo di un flusso usando i delegati. Questo metodo è un helper per StreamSubscriptionHandle.ResumeAsync che consente alla classe di sottoscrizione di inline i metodi del gestore anziché richiedere un'istanza di IAsyncBatchObserver.
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<IList<SequentialItem<T>>,Task>, Func<Task>, StreamSequenceToken)	Riprende l'utilizzo di un flusso usando i delegati. Questo metodo è un helper per StreamSubscriptionHandle.ResumeAsync che consente alla classe di sottoscrizione di inline i metodi del gestore anziché richiedere un'istanza di IAsyncBatchObserver.
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, StreamSequenceToken)	Riprende l'utilizzo di un flusso usando i delegati. Questo metodo è un helper per StreamSubscriptionHandle.ResumeAsync che consente alla classe di sottoscrizione di inline i metodi del gestore anziché richiedere un'istanza di IAsyncObserver.
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<T,StreamSequenceToken,Task>, Func<Task>, StreamSequenceToken)	Riprende l'utilizzo di un flusso usando i delegati. Questo metodo è un helper per StreamSubscriptionHandle.ResumeAsync che consente alla classe di sottoscrizione di inline i metodi del gestore anziché richiedere un'istanza di IAsyncObserver.
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<IList<SequentialItem<T>>,Task>, Func<Exception,Task>, Func<Task>, StreamSequenceToken)	Riprende l'utilizzo di un flusso usando i delegati. Questo metodo è un helper per StreamSubscriptionHandle.ResumeAsync che consente alla classe di sottoscrizione di inline i metodi del gestore anziché richiedere un'istanza di IAsyncBatchObserver.
ResumeAsync<T>(StreamSubscriptionHandle<T>, Func<T,StreamSequenceToken,Task>, Func<Exception,Task>, Func<Task>, StreamSequenceToken)	Riprende l'utilizzo di un flusso usando i delegati. Questo metodo è un helper per StreamSubscriptionHandle.ResumeAsync che consente alla classe di sottoscrizione di inline i metodi del gestore anziché richiedere un'istanza di IAsyncObserver.

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

Generata se la funzione di filtro del flusso fornita non è adatta. In genere ciò è dovuto al fatto che non è un metodo statico.

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

Parametri di tipo

T

Tipo di oggetto prodotto dall'osservabile.

Parametri

handle

StreamSubscriptionHandle<T>

Handle di sottoscrizione.

onNextAsync

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

Delegato chiamato per IAsyncObserver.OnNextAsync.

token

StreamSequenceToken

Sequenza di flusso da utilizzare come offset per avviare la sottoscrizione.

Restituisce

Task<StreamSubscriptionHandle<T>>

Promessa per un oggetto StreamSubscriptionHandle che rappresenta la sottoscrizione. Il consumer può annullare la sottoscrizione usando questo handle. La sottoscrizione rimane attiva finché non viene annullata in modo esplicito.

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

Generata se la funzione di filtro del flusso fornita non è adatta. In genere ciò è dovuto al fatto che non è un metodo statico.

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

Parametri di tipo

T

Tipo di oggetto prodotto dall'osservabile.

Parametri

handle

StreamSubscriptionHandle<T>

Handle di sottoscrizione.

onNextAsync

Func<T,StreamSequenceToken,Task>

Delegato chiamato per IAsyncObserver.OnNextAsync.

token

StreamSequenceToken

Sequenza di flusso da utilizzare come offset per avviare la sottoscrizione.

Restituisce

Task<StreamSubscriptionHandle<T>>

Promessa per un oggetto StreamSubscriptionHandle che rappresenta la sottoscrizione. Il consumer può annullare la sottoscrizione usando questo handle. La sottoscrizione rimane attiva finché non viene annullata in modo esplicito.

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

Riprende l'utilizzo di un flusso usando i delegati. Questo metodo è un helper per StreamSubscriptionHandle.ResumeAsync che consente alla classe di sottoscrizione di inline i metodi del gestore anziché richiedere un'istanza di 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))

Parametri di tipo

T

Tipo di oggetto prodotto dall'osservabile.

Parametri

handle

StreamSubscriptionHandle<T>

Handle di sottoscrizione.

onNextAsync

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

Delegato chiamato per IAsyncObserver.OnNextAsync.

onErrorAsync

Func<Exception,Task>

Delegato chiamato per IAsyncObserver.OnErrorAsync.

token

StreamSequenceToken

Sequenza di flusso da utilizzare come offset per avviare la sottoscrizione.

Restituisce

Task<StreamSubscriptionHandle<T>>

Promessa per un oggetto StreamSubscriptionHandle che rappresenta la sottoscrizione. Il consumer può annullare la sottoscrizione usando questo handle. La sottoscrizione rimane attiva finché non viene annullata in modo esplicito.

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

Riprende l'utilizzo di un flusso usando i delegati. Questo metodo è un helper per StreamSubscriptionHandle.ResumeAsync che consente alla classe di sottoscrizione di inline i metodi del gestore anziché richiedere un'istanza di 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))

Parametri di tipo

T

Tipo di oggetto prodotto dall'osservabile.

Parametri

handle

StreamSubscriptionHandle<T>

Handle di sottoscrizione.

onNextAsync

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

Delegato chiamato per IAsyncObserver.OnNextAsync.

onCompletedAsync

Func<Task>

Delegato chiamato per IAsyncObserver.OnCompletedAsync.

token

StreamSequenceToken

Sequenza di flusso da utilizzare come offset per avviare la sottoscrizione.

Restituisce

Task<StreamSubscriptionHandle<T>>

Promessa per un oggetto StreamSubscriptionHandle che rappresenta la sottoscrizione. Il consumer può annullare la sottoscrizione usando questo handle. La sottoscrizione rimane attiva finché non viene annullata in modo esplicito.

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

Riprende l'utilizzo di un flusso usando i delegati. Questo metodo è un helper per StreamSubscriptionHandle.ResumeAsync che consente alla classe di sottoscrizione di inline i metodi del gestore anziché richiedere un'istanza di 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))

Parametri di tipo

T

Tipo di oggetto prodotto dall'osservabile.

Parametri

handle

StreamSubscriptionHandle<T>

Handle di sottoscrizione.

onNextAsync

Func<T,StreamSequenceToken,Task>

Delegato chiamato per IAsyncObserver.OnNextAsync.

onErrorAsync

Func<Exception,Task>

Delegato chiamato per IAsyncObserver.OnErrorAsync.

token

StreamSequenceToken

Sequenza di flusso da utilizzare come offset per avviare la sottoscrizione.

Restituisce

Task<StreamSubscriptionHandle<T>>

Promessa per un oggetto StreamSubscriptionHandle che rappresenta la sottoscrizione. Il consumer può annullare la sottoscrizione usando questo handle. La sottoscrizione rimane attiva finché non viene annullata in modo esplicito.

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

Riprende l'utilizzo di un flusso usando i delegati. Questo metodo è un helper per StreamSubscriptionHandle.ResumeAsync che consente alla classe di sottoscrizione di inline i metodi del gestore anziché richiedere un'istanza di 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))

Parametri di tipo

T

Tipo di oggetto prodotto dall'osservabile.

Parametri

handle

StreamSubscriptionHandle<T>

Handle di sottoscrizione.

onNextAsync

Func<T,StreamSequenceToken,Task>

Delegato chiamato per IAsyncObserver.OnNextAsync.

onCompletedAsync

Func<Task>

Delegato chiamato per IAsyncObserver.OnCompletedAsync.

token

StreamSequenceToken

Sequenza di flusso da utilizzare come offset per avviare la sottoscrizione.

Restituisce

Task<StreamSubscriptionHandle<T>>

Promessa per un oggetto StreamSubscriptionHandle che rappresenta la sottoscrizione. Il consumer può annullare la sottoscrizione usando questo handle. La sottoscrizione rimane attiva finché non viene annullata in modo esplicito.

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

Riprende l'utilizzo di un flusso usando i delegati. Questo metodo è un helper per StreamSubscriptionHandle.ResumeAsync che consente alla classe di sottoscrizione di inline i metodi del gestore anziché richiedere un'istanza di 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))

Parametri di tipo

T

Tipo di oggetto prodotto dall'osservabile.

Parametri

handle

StreamSubscriptionHandle<T>

Handle di sottoscrizione.

onNextAsync

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

Delegato chiamato per IAsyncObserver.OnNextAsync.

onErrorAsync

Func<Exception,Task>

Delegato chiamato per IAsyncObserver.OnErrorAsync.

onCompletedAsync

Func<Task>

Delegato chiamato per IAsyncObserver.OnCompletedAsync.

token

StreamSequenceToken

Sequenza di flusso da utilizzare come offset per avviare la sottoscrizione.

Restituisce

Task<StreamSubscriptionHandle<T>>

Promessa per un oggetto StreamSubscriptionHandle che rappresenta la sottoscrizione. Il consumer può annullare la sottoscrizione usando questo handle. La sottoscrizione rimane attiva finché non viene annullata in modo esplicito.

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

Riprende l'utilizzo di un flusso usando i delegati. Questo metodo è un helper per StreamSubscriptionHandle.ResumeAsync che consente alla classe di sottoscrizione di inline i metodi del gestore anziché richiedere un'istanza di 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))

Parametri di tipo

T

Tipo di oggetto prodotto dall'osservabile.

Parametri

handle

StreamSubscriptionHandle<T>

Handle di sottoscrizione.

onNextAsync

Func<T,StreamSequenceToken,Task>

Delegato chiamato per IAsyncObserver.OnNextAsync.

onErrorAsync

Func<Exception,Task>

Delegato chiamato per IAsyncObserver.OnErrorAsync.

onCompletedAsync

Func<Task>

Delegato chiamato per IAsyncObserver.OnCompletedAsync.

token

StreamSequenceToken

Sequenza di flusso da utilizzare come offset per avviare la sottoscrizione.

Restituisce

Task<StreamSubscriptionHandle<T>>

Promessa per un oggetto StreamSubscriptionHandle che rappresenta la sottoscrizione. Il consumer può annullare la sottoscrizione usando questo handle. La sottoscrizione rimane attiva finché non viene annullata in modo esplicito.