SubscribeAsync(IAsyncBatchObserver<T>, StreamSequenceToken?)
abstract
public abstract Task<StreamSubscriptionHandle<T>> SubscribeAsync(IAsyncBatchObserver<T> observer, StreamSequenceToken? token) Subscribe a consumer to this batch observable.
Parameters
observerIAsyncBatchObserver<T>- The asynchronous batch observer to subscribe.
tokenStreamSequenceToken?- The stream sequence to be used as an offset to start the subscription from.
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.