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.