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

1. Documentation
2. API reference
3. Microsoft.Orleans.Streaming
4. StreamSubscriptionHandleExtensions
5. Methods
6. ResumeAsync(StreamSubscriptionHandle<T>, Func<T, StreamSequenceToken, Task>, StreamSequenceToken)

Markdown

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

staticextension

View source

public static Task<StreamSubscriptionHandle<T>> ResumeAsync<T>(this StreamSubscriptionHandle<T> handle, Func<T, StreamSequenceToken, Task> onNextAsync, StreamSequenceToken token = null)

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

Parameters

handleStreamSubscriptionHandle<T>

The subscription handle.

onNextAsyncFunc<T, StreamSequenceToken, Task>

Delegate that is called for IAsyncObserver.OnNextAsync.

tokenStreamSequenceToken

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.