Added LoadAsync to EventStore repository

Tacta.EventStore/Repository/EventStoreRepository.cs

@@ -150,5 +150,11 @@ public async Task<IReadOnlyCollection<EventStoreRecord<T>>> GetAsync<T>(string q
                 }
             }
         }
+
+        public async Task<IReadOnlyCollection<EventStoreRecord<T>>> LoadAsync<T>(int offset, int rows, IEnumerable<string> eventsInterestedIn)
+        {
+            var param = new { eventT = eventsInterestedIn };
+            return await GetAsync<T>(StoredEvent.SelectTopOffset(rows, offset), param).ConfigureAwait(false);
+        }
     }
 }

Tacta.EventStore/Repository/IEventStoreRepository.cs

@@ -13,5 +13,6 @@ public interface IEventStoreRepository
         Task<IReadOnlyCollection<EventStoreRecord<T>>> GetUntilAsync<T>(string aggregateId, int sequence);
         Task<int> GetLatestSequence();
         Task<IReadOnlyCollection<EventStoreRecord<T>>> GetAsync<T>(string query, object param);
+        Task<IReadOnlyCollection<EventStoreRecord<T>>> LoadAsync<T>(int offset, int rows, IEnumerable<string> eventsInterestedIn);
     }
 }

Tacta.EventStore/Repository/StoredEvent.cs

@@ -1,4 +1,5 @@
 using System;
+using System.Text;
 
 namespace Tacta.EventStore.Repository
 {
@@ -48,5 +49,14 @@ FROM [dbo].[EventStore]
 
         public static string SelectLatestSequenceQuery =
             @"SELECT MAX ([Sequence]) FROM [dbo].[EventStore]";
+
+        public static string SelectTopOffset(int rows, int offset)
+        {
+            var query = new StringBuilder($@"SELECT TOP({rows}) [Id], [AggregateId], [Version], [CreatedAt], [Payload], [Sequence] 
+                FROM [dbo].[EventStore] 
+                WHERE Sequence>{offset} and Name in @eventT order by Sequence ASC");
+
+            return query.ToString();
+        }
     }
 }