Redigera

Dela via


StreamSubscriptionHandleExtensions.ResumeAsync Method

Definition

Overloads

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

Thrown if the supplied stream filter function is not suitable. Usually this is because it is not a static method.

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

Thrown if the supplied stream filter function is not suitable. Usually this is because it is not a static method.

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

Resumes consumption of a stream using delegates. This method is a helper for the StreamSubscriptionHandle.ResumeAsync allowing the subscribing class to inline the handler methods instead of requiring an instance of IAsyncBatchObserver.

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

Resumes consumption of a stream using delegates. This method is a helper for the StreamSubscriptionHandle.ResumeAsync allowing the subscribing class to inline the handler methods instead of requiring an instance of IAsyncBatchObserver.

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

Resumes consumption of a stream using delegates. This method is a helper for the StreamSubscriptionHandle.ResumeAsync allowing the subscribing class to inline the handler methods instead of requiring an instance of IAsyncObserver.

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

Resumes consumption of a stream using delegates. This method is a helper for the StreamSubscriptionHandle.ResumeAsync allowing the subscribing class to inline the handler methods instead of requiring an instance of IAsyncObserver.

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

Resumes consumption of a stream using delegates. This method is a helper for the StreamSubscriptionHandle.ResumeAsync allowing the subscribing class to inline the handler methods instead of requiring an instance of IAsyncBatchObserver.

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

Resumes consumption of a stream using delegates. This method is a helper for the StreamSubscriptionHandle.ResumeAsync allowing the subscribing class to inline the handler methods instead of requiring an instance of IAsyncObserver.

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

Source:
StreamSubscriptionHandleExtensions.cs

Thrown if the supplied stream filter function is not suitable. Usually this is because it is not a static method.

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

Type Parameters

T

The type of object produced by the observable.

Parameters

handle
StreamSubscriptionHandle<T>

The subscription handle.

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

Delegate that is called for IAsyncObserver.OnNextAsync.

token
StreamSequenceToken

The stream sequence to be used as an offset to start the subscription from.

Returns

A promise for a StreamSubscriptionHandle that represents the subscription. The consumer may unsubscribe by using this handle. The subscription remains active for as long as it is not explicitly unsubscribed.

Applies to

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

Source:
StreamSubscriptionHandleExtensions.cs

Thrown if the supplied stream filter function is not suitable. Usually this is because it is not a static method.

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

Type Parameters

T

The type of object produced by the observable.

Parameters

handle
StreamSubscriptionHandle<T>

The subscription handle.

onNextAsync
Func<T,StreamSequenceToken,Task>

Delegate that is called for IAsyncObserver.OnNextAsync.

token
StreamSequenceToken

The stream sequence to be used as an offset to start the subscription from.

Returns

A promise for a StreamSubscriptionHandle that represents the subscription. The consumer may unsubscribe by using this handle. The subscription remains active for as long as it is not explicitly unsubscribed.

Applies to

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

Source:
StreamSubscriptionHandleExtensions.cs

Resumes consumption of a stream using delegates. This method is a helper for the StreamSubscriptionHandle.ResumeAsync allowing the subscribing class to inline the handler methods instead of requiring an instance of 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))

Type Parameters

T

The type of object produced by the observable.

Parameters

handle
StreamSubscriptionHandle<T>

The subscription handle.

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

Delegate that is called for IAsyncObserver.OnNextAsync.

onErrorAsync
Func<Exception,Task>

Delegate that is called for IAsyncObserver.OnErrorAsync.

token
StreamSequenceToken

The stream sequence to be used as an offset to start the subscription from.

Returns

A promise for a StreamSubscriptionHandle that represents the subscription. The consumer may unsubscribe by using this handle. The subscription remains active for as long as it is not explicitly unsubscribed.

Applies to

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

Source:
StreamSubscriptionHandleExtensions.cs

Resumes consumption of a stream using delegates. This method is a helper for the StreamSubscriptionHandle.ResumeAsync allowing the subscribing class to inline the handler methods instead of requiring an instance of 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))

Type Parameters

T

The type of object produced by the observable.

Parameters

handle
StreamSubscriptionHandle<T>

The subscription handle.

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

Delegate that is called for IAsyncObserver.OnNextAsync.

onCompletedAsync
Func<Task>

Delegate that is called for IAsyncObserver.OnCompletedAsync.

token
StreamSequenceToken

The stream sequence to be used as an offset to start the subscription from.

Returns

A promise for a StreamSubscriptionHandle that represents the subscription. The consumer may unsubscribe by using this handle. The subscription remains active for as long as it is not explicitly unsubscribed.

Applies to

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

Source:
StreamSubscriptionHandleExtensions.cs

Resumes consumption of a stream using delegates. This method is a helper for the StreamSubscriptionHandle.ResumeAsync allowing the subscribing class to inline the handler methods instead of requiring an instance of 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))

Type Parameters

T

The type of object produced by the observable.

Parameters

handle
StreamSubscriptionHandle<T>

The subscription handle.

onNextAsync
Func<T,StreamSequenceToken,Task>

Delegate that is called for IAsyncObserver.OnNextAsync.

onErrorAsync
Func<Exception,Task>

Delegate that is called for IAsyncObserver.OnErrorAsync.

token
StreamSequenceToken

The stream sequence to be used as an offset to start the subscription from.

Returns

A promise for a StreamSubscriptionHandle that represents the subscription. The consumer may unsubscribe by using this handle. The subscription remains active for as long as it is not explicitly unsubscribed.

Applies to

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

Source:
StreamSubscriptionHandleExtensions.cs

Resumes consumption of a stream using delegates. This method is a helper for the StreamSubscriptionHandle.ResumeAsync allowing the subscribing class to inline the handler methods instead of requiring an instance of 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))

Type Parameters

T

The type of object produced by the observable.

Parameters

handle
StreamSubscriptionHandle<T>

The subscription handle.

onNextAsync
Func<T,StreamSequenceToken,Task>

Delegate that is called for IAsyncObserver.OnNextAsync.

onCompletedAsync
Func<Task>

Delegate that is called for IAsyncObserver.OnCompletedAsync.

token
StreamSequenceToken

The stream sequence to be used as an offset to start the subscription from.

Returns

A promise for a StreamSubscriptionHandle that represents the subscription. The consumer may unsubscribe by using this handle. The subscription remains active for as long as it is not explicitly unsubscribed.

Applies to

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

Source:
StreamSubscriptionHandleExtensions.cs

Resumes consumption of a stream using delegates. This method is a helper for the StreamSubscriptionHandle.ResumeAsync allowing the subscribing class to inline the handler methods instead of requiring an instance of 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))

Type Parameters

T

The type of object produced by the observable.

Parameters

handle
StreamSubscriptionHandle<T>

The subscription handle.

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

Delegate that is called for IAsyncObserver.OnNextAsync.

onErrorAsync
Func<Exception,Task>

Delegate that is called for IAsyncObserver.OnErrorAsync.

onCompletedAsync
Func<Task>

Delegate that is called for IAsyncObserver.OnCompletedAsync.

token
StreamSequenceToken

The stream sequence to be used as an offset to start the subscription from.

Returns

A promise for a StreamSubscriptionHandle that represents the subscription. The consumer may unsubscribe by using this handle. The subscription remains active for as long as it is not explicitly unsubscribed.

Applies to

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

Source:
StreamSubscriptionHandleExtensions.cs

Resumes consumption of a stream using delegates. This method is a helper for the StreamSubscriptionHandle.ResumeAsync allowing the subscribing class to inline the handler methods instead of requiring an instance of 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))

Type Parameters

T

The type of object produced by the observable.

Parameters

handle
StreamSubscriptionHandle<T>

The subscription handle.

onNextAsync
Func<T,StreamSequenceToken,Task>

Delegate that is called for IAsyncObserver.OnNextAsync.

onErrorAsync
Func<Exception,Task>

Delegate that is called for IAsyncObserver.OnErrorAsync.

onCompletedAsync
Func<Task>

Delegate that is called for IAsyncObserver.OnCompletedAsync.

token
StreamSequenceToken

The stream sequence to be used as an offset to start the subscription from.

Returns

A promise for a StreamSubscriptionHandle that represents the subscription. The consumer may unsubscribe by using this handle. The subscription remains active for as long as it is not explicitly unsubscribed.

Applies to