AsyncBatchObservableExtensions

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

class

Namespace: Orleans.Streams

NuGetSourceMarkdown

Extension methods for Orleans.Streams.IAsyncBatchObservable.

public static class AsyncBatchObservableExtensions

Methods

• SubscribeAsync(IAsyncBatchObservable<T>, Func<IList<SequentialItem<T>>, Task>) Subscribe a consumer to this observable using delegates. This method is a helper for the IAsyncBatchObservable.SubscribeAsync allowing the subscribing class to inline the handler methods instead of requiring an instance of IAsyncBatchObserver.
• SubscribeAsync(IAsyncBatchObservable<T>, Func<IList<SequentialItem<T>>, Task>, Func<Exception, Task>) Subscribe a consumer to this observable using delegates. This method is a helper for the IAsyncBatchObservable.SubscribeAsync allowing the subscribing class to inline the handler methods instead of requiring an instance of IAsyncBatchObserver.
• SubscribeAsync(IAsyncBatchObservable<T>, Func<IList<SequentialItem<T>>, Task>, Func<Exception, Task>, Func<Task>) Subscribe a consumer to this observable using delegates. This method is a helper for the IAsyncBatchObservable.SubscribeAsync allowing the subscribing class to inline the handler methods instead of requiring an instance of IAsyncBatchObserver.
• SubscribeAsync(IAsyncBatchObservable<T>, Func<IList<SequentialItem<T>>, Task>, Func<Task>) Subscribe a consumer to this observable using delegates. This method is a helper for the IAsyncBatchObservable.SubscribeAsync allowing the subscribing class to inline the handler methods instead of requiring an instance of IAsyncBatchObserver.