SubscribeAsync(IAsyncObservable<T>, IAsyncObserver<T>, StreamSubscriptionStartPosition, string?)
staticextension
public static Task<StreamSubscriptionHandle<T>> SubscribeAsync<T>(this IAsyncObservable<T> obs, IAsyncObserver<T> observer, StreamSubscriptionStartPosition startPosition, string? filterData = null) Subscribe a consumer to this observable using the specified initial position.
Parameters
obsIAsyncObservable<T>- The observable.
observerIAsyncObserver<T>- The asynchronous observer to subscribe.
startPositionStreamSubscriptionStartPosition- The initial subscription position.
filterDatastring?- Data object that will be passed to the filter.
Returns
A promise for a
Orleans.Streams.StreamSubscriptionHandle that represents the subscription.