SubscribeAsync(IAsyncObserver<T>, StreamSequenceToken?, string?)
abstract
public abstract Task<StreamSubscriptionHandle<T>> SubscribeAsync(IAsyncObserver<T> observer, StreamSequenceToken? token, string? filterData = null) Subscribe a consumer to this observable.
Parameters
observerIAsyncObserver<T>- The asynchronous observer to subscribe.
tokenStreamSequenceToken?- The stream sequence to be used as an offset to start the subscription from.
filterDatastring?- Data object that will be passed in to the filter.
Returns
A promise for a StreamSubscriptionHandle that represents the subscription. The consumer may unsubscribe by using this handle. The subscription remains active for as long as it is not explicitly unsubscribed.