Closed dennisdoomen closed 7 years ago
Adding another delegate would mean the subscription delegate will start to look like this;
public delegate IDisposable CreateSubscription(long? lastProcessedCheckpoint,
Func<IReadOnlyList<Transaction>, SubscriptionInfo, Task> handler, Func<Task> noSuchCheckpoint,
string subscriptionId);
Feels a bit awkward. What do you think?
@IharBury please review again. I've applied your proposal.
Adds a new options object that allows a subscriber to tell the dispatcher to restart the subscription at the first transaction available in the underlying event source, and allow the subscriber to clean-up just before that.