ResumeAsync(StreamSubscriptionHandle<T>, Func<T, StreamSequenceToken, Task>, Func<Task>, StreamSequenceToken)
staticextension
public static Task<StreamSubscriptionHandle<T>> ResumeAsync<T>(this StreamSubscriptionHandle<T> handle, Func<T, StreamSequenceToken, Task> onNextAsync, Func<Task> onCompletedAsync, StreamSequenceToken token = null) 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.
Parameters
handleStreamSubscriptionHandle<T>- The subscription handle.
onNextAsyncFunc<T, StreamSequenceToken, Task>- Delegate that is called for IAsyncObserver.OnNextAsync.
onCompletedAsyncFunc<Task>- Delegate that is called for IAsyncObserver.OnCompletedAsync.
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.