AsyncBatchObservableExtensions.SubscribeAsync(IAsyncBatchObservable<T>, IAsyncBatchObserver<T>, StreamSubscriptionStartPosition)

1. Documentation
2. API reference
3. Microsoft.Orleans.Streaming
4. AsyncBatchObservableExtensions
5. Methods
6. SubscribeAsync(IAsyncBatchObservable<T>, IAsyncBatchObserver<T>, StreamSubscriptionStartPosition)

Markdown

SubscribeAsync(IAsyncBatchObservable<T>, IAsyncBatchObserver<T>, StreamSubscriptionStartPosition)

staticextension

View source

public static Task<StreamSubscriptionHandle<T>> SubscribeAsync<T>(this IAsyncBatchObservable<T> obs, IAsyncBatchObserver<T> observer, StreamSubscriptionStartPosition startPosition)

Subscribe a consumer to this batch observable using the specified initial position.

Parameters

obsIAsyncBatchObservable<T>

The observable.

observerIAsyncBatchObserver<T>

The asynchronous batch observer to subscribe.

startPositionStreamSubscriptionStartPosition

The initial subscription position.

Returns

A promise for a Orleans.Streams.StreamSubscriptionHandle that represents the subscription.