Another small off-by-one fix on the in-memory event store provider. (#78

)
liquidprojections · Feb 16, 2017 · 92f6ff0 · 92f6ff0
1 parent fe051e5
commit 92f6ff0
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/Src/LiquidProjections.Testing/InMemoryEventStore.cs b/Src/LiquidProjections.Testing/InMemoryEventStore.cs
@@ -121,7 +121,7 @@ public async Task Send(IEnumerable<Transaction> transactions)
         {
             if (!disposed)
             {
-                foreach (var batch in transactions.Where(t => t.Checkpoint >= lastProcessedCheckpoint).InBatchesOf(batchSize))
+                foreach (var batch in transactions.Where(t => t.Checkpoint > lastProcessedCheckpoint).InBatchesOf(batchSize))
                 {
                     await handler(batch.ToList().AsReadOnly()).ConfigureAwait(false);
                 }
@@ -133,4 +133,4 @@ public void Dispose()
             disposed = true;
         }
     }
-}
+}