Persisted projection defaults changed with min checkpoint to 1.

Author: Rafał Maciąg

src/MicroPlumberd.Services.LiteDb/Class1.cs

@@ -155,6 +155,13 @@ public async Task<IAsyncDisposable> SubscribeEventHandler<TEventHandler>(TEventH
             throw new NotImplementedException();
         }
 
+        public async Task<IAsyncDisposable> SubscribeEventHandlerPersistently<TEventHandler>(TEventHandler? model = default(TEventHandler?),
+            string? outputStream = null, string? groupName = null, IPosition? startFrom = null,
+            bool ensureOutputStreamProjection = true, int minCheckPointCount = 1, CancellationToken token = default) where TEventHandler : class, IEventHandler, ITypeRegister
+        {
+            throw new NotImplementedException();
+        }
+
         public async Task<T> Get<T>(object id, CancellationToken token = default) where T : IAggregate<T>, ITypeRegister, IId
         {
             throw new NotImplementedException();
@@ -247,6 +254,13 @@ public IAsyncEnumerable<object> Read<TOwner>(StreamPosition? start = null, Direc
             throw new NotImplementedException();
         }
 
+        public async Task<IAsyncDisposable> SubscribeEventHandlerPersistently<TEventHandler>(TypeEventConverter mapFunc, IEnumerable<string>? events,
+            TEventHandler? model, string? outputStream = null, string? groupName = null, IPosition? startFrom = null,
+            bool ensureOutputStreamProjection = true, int minCheckPointCount = 1, CancellationToken token = default) where TEventHandler : class, IEventHandler
+        {
+            throw new NotImplementedException();
+        }
+
         public IAsyncEnumerable<object> Read<TOwner>(object id, StreamPosition? start = null, Direction? direction = null,
             long maxCount = 9223372036854775807, CancellationToken token = default) where TOwner : ITypeRegister
         {

src/MicroPlumberd/Abstractions/IPlumber.cs

@@ -229,7 +229,8 @@ Task<IAsyncDisposable> SubscribeEventHandler<TEventHandler>(TEventHandler? eh =
     /// <param name="ensureOutputStreamProjection">when true creates projection that creates output's stream</param>
     /// <param name="token"></param>
     /// <returns></returns>
-    Task<IAsyncDisposable> SubscribeEventHandlerPersistently<TEventHandler>(TEventHandler? model=null, string? outputStream = null, string? groupName = null, IPosition? startFrom = null, bool ensureOutputStreamProjection = true, CancellationToken token = default) where TEventHandler : class,IEventHandler, ITypeRegister;
+    Task<IAsyncDisposable> SubscribeEventHandlerPersistently<TEventHandler>(TEventHandler? model=null, string? outputStream = null, string? groupName = null, IPosition? startFrom = null, bool ensureOutputStreamProjection = true, int minCheckPointCount=1, CancellationToken token = default) 
+        where TEventHandler : class,IEventHandler, ITypeRegister;
 
     /// <summary>
     /// Returns a subscription builder that will subscribe model persistently.
@@ -240,7 +241,7 @@ Task<IAsyncDisposable> SubscribeEventHandler<TEventHandler>(TEventHandler? eh =
     /// <param name="userCredentials">The user credentials.</param>
     /// <param name="cancellationToken">The cancellation token.</param>
     /// <returns></returns>
-    ISubscriptionRunner SubscribePersistently(string streamName, string groupName, int bufferSize = 10, UserCredentials? userCredentials = null, CancellationToken cancellationToken = new CancellationToken());
+    ISubscriptionRunner SubscribePersistently(string streamName, string groupName, int bufferSize = 10, UserCredentials? userCredentials = null,CancellationToken cancellationToken = new CancellationToken());
 
     /// <summary>
     /// Rehydrates the specified model.
@@ -341,7 +342,7 @@ Task<IAsyncDisposable> SubscribeEventHandlerPersistently<TEventHandler>(TypeEven
         IEnumerable<string>? events,
         TEventHandler? model,
         string? outputStream = null, string? groupName = null, IPosition? startFrom = null,
-        bool ensureOutputStreamProjection = true, CancellationToken token = default)
+        bool ensureOutputStreamProjection = true,int minCheckPointCount=1, CancellationToken token = default)
         where TEventHandler : class, IEventHandler;
 
     /// <summary>

src/MicroPlumberd/Plumber.cs

@@ -135,7 +135,9 @@ public async Task<IAsyncDisposable> SubscribeEventHandlerPersistently<TEventHand
         IEnumerable<string>? events,
         TEventHandler? model,
         string? outputStream = null, string? groupName = null, IPosition? startFrom = null,
-        bool ensureOutputStreamProjection = true, CancellationToken token = default)
+        bool ensureOutputStreamProjection = true, 
+        int minCheckpointCount = 1,
+        CancellationToken token = default)
         where TEventHandler : class, IEventHandler
     {
         var handlerType = typeof(TEventHandler);
@@ -152,7 +154,7 @@ public async Task<IAsyncDisposable> SubscribeEventHandlerPersistently<TEventHand
         catch (PersistentSubscriptionNotFoundException)
         {
             await PersistentSubscriptionClient.CreateToStreamAsync(outputStream, groupName,
-                new PersistentSubscriptionSettings(true, startFrom), cancellationToken: token);
+                new PersistentSubscriptionSettings(true, startFrom, checkPointLowerBound: minCheckpointCount), cancellationToken: token);
         }
 
         var sub = SubscribePersistently(outputStream, groupName, cancellationToken:token);
@@ -166,20 +168,20 @@ await PersistentSubscriptionClient.CreateToStreamAsync(outputStream, groupName,
 
     public Task<IAsyncDisposable> SubscribeEventHandlerPersistently<TEventHandler>(TEventHandler? model,
         string? outputStream = null, string? groupName = null, IPosition? startFrom = null,
-        bool ensureOutputStreamProjection = true, CancellationToken token = default)
+        bool ensureOutputStreamProjection = true, int minCheckPointCount = 1, CancellationToken token = default)
         where TEventHandler : class, IEventHandler, ITypeRegister
     {
         return SubscribeEventHandlerPersistently(_typeHandlerRegisters.GetEventNameConverterFor<TEventHandler>(),
             _typeHandlerRegisters.GetEventNamesFor<TEventHandler>(),
-            model, outputStream, groupName, startFrom, ensureOutputStreamProjection, token);
+            model, outputStream, groupName, startFrom, ensureOutputStreamProjection, minCheckPointCount, token);
     }
 
 
-    public ISubscriptionRunner SubscribePersistently(string streamName, string groupName, int bufferSize = 10,
+    public ISubscriptionRunner SubscribePersistently(string streamName, string groupName, int bufferSize = 10, 
         UserCredentials? userCredentials = null, CancellationToken cancellationToken = default)
     {
         return new PersistentSubscriptionRunner(this,
-            PersistentSubscriptionClient.SubscribeToStream(streamName, groupName, bufferSize, userCredentials,
+            PersistentSubscriptionClient.SubscribeToStream(streamName, groupName, bufferSize,  userCredentials,
                 cancellationToken));
     }