AsyncObservableExtensions

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

class

Namespace: Orleans.Streams

NuGetSourceMarkdown

Extension methods for Orleans.Streams.IAsyncObservable.

public static class AsyncObservableExtensions

Methods

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