Used async enumerators

src/MemState.EventStore/EventStoreReader.cs

@@ -37,15 +37,15 @@ public Task DisposeAsync()
             return Task.CompletedTask;
         }
 
-        public IEnumerable<JournalRecord> GetRecords(long fromRecord = 0)
+        public async IAsyncEnumerable<JournalRecord> GetRecords(long fromRecord = 0)
         {
             var nextRecord = fromRecord;
 
             _logger.Info("GetRecords from {0}", nextRecord);
 
             while (true)
             {
-                var slice = _connection.ReadStreamEventsForwardAsync(_streamName, nextRecord, _eventsPerSlice, false).Result;
+                var slice = await _connection.ReadStreamEventsForwardAsync(_streamName, nextRecord, _eventsPerSlice, false);
 
                 _logger.Debug("{0} events in slice from {0}", slice.Events.Length, slice.FromEventNumber);
 

src/Memstate.Core/EngineBuilder.cs

@@ -53,10 +53,10 @@ public async Task<Engine<T>> Build<T>(T initialState) where T : class
             return new Engine<T>(_settings, model, subscriptionSource, writer, nextRecordNumber);
         }
 
-        internal static TState Load<TState>(IJournalReader reader, TState initial, out long lastRecordNumber)
+        internal static async Task<TState> Load<TState>(IJournalReader reader, TState initial, out long lastRecordNumber)
         {
             lastRecordNumber = -1;
-            foreach (var journalRecord in reader.GetRecords())
+            await foreach (var journalRecord in reader.GetRecords())
             {
                 try
                 {

src/Memstate.Core/IJournalReader.cs

@@ -4,6 +4,6 @@ namespace Memstate
 {
     public interface IJournalReader : IAsyncDisposable
     {
-        IEnumerable<JournalRecord> GetRecords(long fromRecord = 0);
+        IAsyncEnumerable<JournalRecord> GetRecords(long fromRecord = 0);
     }
 }

src/Memstate.Core/NullJournalReader.cs

@@ -10,7 +10,7 @@ public Task DisposeAsync()
             return Task.CompletedTask;
         }
 
-        public IEnumerable<JournalRecord> GetRecords(long fromRecord = 0)
+        public async IAsyncEnumerable<JournalRecord> GetRecords(long fromRecord = 0)
         {
             yield break;
         }

src/Memstate.Core/Storage/FileJournalReader.cs

@@ -25,9 +25,10 @@ public Task DisposeAsync()
             return Task.Run((Action) _journalStream.Dispose);
         }
 
-        public IEnumerable<JournalRecord> GetRecords(long fromRecord = 0)
+        public async IAsyncEnumerable<JournalRecord> GetRecords(long fromRecord = 0)
         {
-            foreach (var record in _serializer.ReadObjects<JournalRecord>(_journalStream))
+            var records = await Task.Run(() => _serializer.ReadObjects<JournalRecord>(_journalStream));
+            await foreach (var record in records)
             {
                 if (record.RecordNumber >= fromRecord)
                 {