IAsyncObservable<T>

1. Documentation
2. API reference
3. Microsoft.Orleans.Streaming
4. IAsyncObservable<T>

interface

Namespace: Orleans.Streams

NuGetSourceMarkdown

This interface generalizes the standard .NET IObserveable interface to allow asynchronous consumption of items. Asynchronous here means that the consumer can process items asynchronously and signal item completion to the producer by completing the returned Task.

Note that this interface is invoked (used) by item consumers and implemented by item producers. This means that the producer endpoint of a stream implements this interface.

public interface IAsyncObservable<T>

Methods

• SubscribeAsync(IAsyncObserver<T>) Subscribe a consumer to this observable.
• SubscribeAsync(IAsyncObserver<T>, StreamSequenceToken?, string?) Subscribe a consumer to this observable.