StreamSubscriptionHandleExtensions

1. Documentation
2. API reference
3. Microsoft.Orleans.Streaming
4. StreamSubscriptionHandleExtensions

class

Namespace: Orleans.Streams

NuGetSourceMarkdown

Extension methods for Orleans.Streams.StreamSubscriptionHandle.

public static class StreamSubscriptionHandleExtensions

Methods

• ResumeAsync(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(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(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(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(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(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(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(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.