Update ElasticSearch to v1

MMonrad · MMonrad · commit ac75e965d340 · 2025-03-09T19:44:23.000+01:00
diff --git a/EventFlow.sln b/EventFlow.sln
@@ -74,6 +74,12 @@ Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "EventFlow.SourceGenerators"
 EndProject
 Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "EventFlow.SourceGenerators.Tests", "Source\EventFlow.SourceGenerators.Tests\EventFlow.SourceGenerators.Tests.csproj", "{D8317769-F140-4E5D-9041-19342A3A33BD}"
 EndProject
+Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "ElasticSearch", "ElasticSearch", "{B684211A-CF37-4A6A-BF1B-460D0369DD61}"
+EndProject
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "EventFlow.Elasticsearch", "Source\EventFlow.Elasticsearch\EventFlow.Elasticsearch.csproj", "{199E59E3-C674-4D8E-B31D-699C7331F4CA}"
+EndProject
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "EventFlow.Elasticsearch.Tests", "Source\EventFlow.Elasticsearch.Tests\EventFlow.Elasticsearch.Tests.csproj", "{20775513-2FA6-4148-8068-B7C0AA08EB76}"
+EndProject
 Global
 	GlobalSection(SolutionConfigurationPlatforms) = preSolution
 		Debug|Any CPU = Debug|Any CPU
@@ -172,6 +178,14 @@ Global
 		{D8317769-F140-4E5D-9041-19342A3A33BD}.Debug|Any CPU.Build.0 = Debug|Any CPU
 		{D8317769-F140-4E5D-9041-19342A3A33BD}.Release|Any CPU.ActiveCfg = Release|Any CPU
 		{D8317769-F140-4E5D-9041-19342A3A33BD}.Release|Any CPU.Build.0 = Release|Any CPU
+		{199E59E3-C674-4D8E-B31D-699C7331F4CA}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{199E59E3-C674-4D8E-B31D-699C7331F4CA}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{199E59E3-C674-4D8E-B31D-699C7331F4CA}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{199E59E3-C674-4D8E-B31D-699C7331F4CA}.Release|Any CPU.Build.0 = Release|Any CPU
+		{20775513-2FA6-4148-8068-B7C0AA08EB76}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{20775513-2FA6-4148-8068-B7C0AA08EB76}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{20775513-2FA6-4148-8068-B7C0AA08EB76}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{20775513-2FA6-4148-8068-B7C0AA08EB76}.Release|Any CPU.Build.0 = Release|Any CPU
 	EndGlobalSection
 	GlobalSection(SolutionProperties) = preSolution
 		HideSolutionNode = FALSE
@@ -208,6 +222,9 @@ Global
 		{91929C7C-D9AE-B5BA-2467-C9FCAEC69696} = {5EE323DE-E69B-451A-8AC3-22DD6A004FBA}
 		{35098BEA-A0B8-4E63-8D71-35CE5297B459} = {91929C7C-D9AE-B5BA-2467-C9FCAEC69696}
 		{D8317769-F140-4E5D-9041-19342A3A33BD} = {91929C7C-D9AE-B5BA-2467-C9FCAEC69696}
+		{B684211A-CF37-4A6A-BF1B-460D0369DD61} = {5EE323DE-E69B-451A-8AC3-22DD6A004FBA}
+		{199E59E3-C674-4D8E-B31D-699C7331F4CA} = {B684211A-CF37-4A6A-BF1B-460D0369DD61}
+		{20775513-2FA6-4148-8068-B7C0AA08EB76} = {B684211A-CF37-4A6A-BF1B-460D0369DD61}
 	EndGlobalSection
 	GlobalSection(ExtensibilityGlobals) = postSolution
 		SolutionGuid = {17607E2C-4E8E-45A2-85BD-0A5808E1C0F3}
diff --git a/README.md b/README.md
@@ -64,7 +64,7 @@ The following list key characteristics of each version as well as its related br
     - 🟠 `EventFlow.AspNetCore`
     - 💀 `EventFlow.Autofac`
     - 💀 `EventFlow.DependencyInjection`
-    - 🟠 `EventFlow.Elasticsearch`
+    - 🟢 `EventFlow.Elasticsearch`
     - 🟢 `EventFlow.EntityFramework`
     - 🟠 `EventFlow.EventStores.EventStore`
     - 🟢 `EventFlow.Hangfire`
diff --git a/RELEASE_NOTES.md b/RELEASE_NOTES.md
@@ -1,4 +1,5 @@
 ### New in 1.2.0 (working version, not released yet)
+* New: NuGet `EventFlow.Elasticsearch` now ported to v1 (thanks @MMonrad)
 
 * New: New NuGet package `EventFlow.SourceGenerators` created by @alexeyfv. See
   [documentation](https://geteventflow.net/additional/source-generation/) for details
diff --git a/Source/EventFlow.Elasticsearch.Tests/EventFlow.Elasticsearch.Tests.csproj b/Source/EventFlow.Elasticsearch.Tests/EventFlow.Elasticsearch.Tests.csproj
@@ -1,7 +1,6 @@
 ﻿<Project Sdk="Microsoft.NET.Sdk">
-  <Import Project="../Common.props" />
   <PropertyGroup>
-    <TargetFramework>netcoreapp3.1</TargetFramework>
+    <TargetFramework>net8.0</TargetFramework>
     <TreatWarningsAsErrors>True</TreatWarningsAsErrors>
     <GenerateAssemblyInfo>False</GenerateAssemblyInfo>
     <IsPackable>False</IsPackable>
@@ -11,13 +10,16 @@
   </ItemGroup>
   <ItemGroup>
     <PackageReference Include="Microsoft.NET.Test.Sdk" Version="16.6.1" />
-    <PackageReference Include="NUnit" Version="3.12.0" />
+    <PackageReference Include="NUnit" Version="3.13.2" />
     <PackageReference Include="NUnit3TestAdapter" Version="3.17.0" />
   </ItemGroup>
+
   <ItemGroup>
     <ProjectReference Include="..\EventFlow.Elasticsearch\EventFlow.Elasticsearch.csproj" />
     <ProjectReference Include="..\EventFlow.TestHelpers\EventFlow.TestHelpers.csproj" />
+    <ProjectReference Include="..\EventFlow\EventFlow.csproj" />
   </ItemGroup>
+  
   <ItemGroup>
     <Service Include="{82a7f48d-3b50-4b1e-b82e-3ada8210c358}" />
   </ItemGroup>
diff --git a/Source/EventFlow.Elasticsearch.Tests/IntegrationTests/ElasticsearchReadModelStoreTests.cs b/Source/EventFlow.Elasticsearch.Tests/IntegrationTests/ElasticsearchReadModelStoreTests.cs
@@ -37,6 +37,7 @@
 using EventFlow.TestHelpers.Aggregates;
 using EventFlow.TestHelpers.Aggregates.Entities;
 using EventFlow.TestHelpers.Suites;
+using Microsoft.Extensions.DependencyInjection;
 using Nest;
 using NUnit.Framework;
 using IndexName = EventFlow.Elasticsearch.ValueObjects.IndexName;
@@ -52,7 +53,7 @@ public class ElasticsearchReadModelStoreTests : TestSuiteForReadModelStore
 
         private readonly List<string> _indexes = new List<string>();
 
-        protected override IRootResolver CreateRootResolver(IEventFlowOptions eventFlowOptions)
+        protected override IServiceProvider Configure(IEventFlowOptions eventFlowOptions)
         {
             var elasticsearchUrl = Environment.GetEnvironmentVariable("ELASTICSEARCH_URL") ?? "http://localhost:9200";
 
@@ -63,25 +64,25 @@ protected override IRootResolver CreateRootResolver(IEventFlowOptions eventFlowO
                 .SniffLifeSpan(TimeSpan.FromMinutes(5))
                 .DisablePing();
            
-            var resolver = eventFlowOptions
-                .RegisterServices(sr => { sr.RegisterType(typeof(ThingyMessageLocator)); })
+            var options = eventFlowOptions
+                .RegisterServices(sr => { sr.AddTransient<ThingyMessageLocator>(); })
                 .ConfigureElasticsearch(connectionSettings)
                 .UseElasticsearchReadModel<ElasticsearchThingyReadModel>()
                 .UseElasticsearchReadModel<ElasticsearchThingyMessageReadModel, ThingyMessageLocator>()
                 .AddQueryHandlers(
                     typeof(ElasticsearchThingyGetQueryHandler),
                     typeof(ElasticsearchThingyGetVersionQueryHandler),
-                    typeof(ElasticsearchThingyGetMessagesQueryHandler))
-                .CreateResolver();
+                    typeof(ElasticsearchThingyGetMessagesQueryHandler));
 
-            PrepareIndexes(resolver);
+            PrepareIndexes(options);
 
-            return resolver;
+            return base.Configure(eventFlowOptions);
         }
 
-        private void PrepareIndexes(IRootResolver resolver)
+        private void PrepareIndexes(IEventFlowOptions options)
         {
-            _elasticClient = resolver.Resolve<IElasticClient>();
+            using var provider = options.ServiceCollection.BuildServiceProvider();
+            _elasticClient = provider.GetRequiredService<IElasticClient>();
 
             var readModelTypes =
                 GetLoadableTypes<ElasticsearchTypeAttribute>(typeof(ElasticsearchThingyReadModel).Assembly);
diff --git a/Source/EventFlow.Elasticsearch.Tests/IntegrationTests/ReadModels/ElasticsearchThingyMessageReadModel.cs b/Source/EventFlow.Elasticsearch.Tests/IntegrationTests/ReadModels/ElasticsearchThingyMessageReadModel.cs
@@ -21,56 +21,63 @@
 // CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
 
 using System.Linq;
+using System.Threading;
+using System.Threading.Tasks;
 using EventFlow.Aggregates;
 using EventFlow.ReadStores;
 using EventFlow.TestHelpers.Aggregates;
 using EventFlow.TestHelpers.Aggregates.Entities;
 using EventFlow.TestHelpers.Aggregates.Events;
 using Nest;
 
-namespace EventFlow.Elasticsearch.Tests.IntegrationTests.ReadModels
+namespace EventFlow.Elasticsearch.Tests.IntegrationTests.ReadModels;
+
+[ElasticsearchType(IdProperty = "Id", RelationName = "message")]
+public class ElasticsearchThingyMessageReadModel : IReadModel,
+    IAmReadModelFor<ThingyAggregate, ThingyId, ThingyMessageAddedEvent>,
+    IAmReadModelFor<ThingyAggregate, ThingyId, ThingyMessageHistoryAddedEvent>
 {
-    [ElasticsearchType(IdProperty = "Id", RelationName = "message")]
-    public class ElasticsearchThingyMessageReadModel : IReadModel,
-        IAmReadModelFor<ThingyAggregate, ThingyId, ThingyMessageAddedEvent>,
-        IAmReadModelFor<ThingyAggregate, ThingyId, ThingyMessageHistoryAddedEvent>
-    {
-        public string Id { get; set; }
+    public string Id { get; set; }
 
-        [Keyword(
-            Name = "ThingyId",
-            Index = true)]
-        public string ThingyId { get; set; }
+    [Keyword(
+        Name = "ThingyId",
+        Index = true)]
+    public string ThingyId { get; set; }
 
-        [Text(
-            Name = "Message",
-            Index = false)]
-        public string Message { get; set; }
+    [Text(
+        Name = "Message",
+        Index = false)]
+    public string Message { get; set; }
 
-        public void Apply(IReadModelContext context, IDomainEvent<ThingyAggregate, ThingyId, ThingyMessageAddedEvent> domainEvent)
-        {
-            ThingyId = domainEvent.AggregateIdentity.Value;
+    public Task ApplyAsync(IReadModelContext context,
+        IDomainEvent<ThingyAggregate, ThingyId, ThingyMessageAddedEvent> domainEvent,
+        CancellationToken cancellationToken)
+    {
+        ThingyId = domainEvent.AggregateIdentity.Value;
 
-            var thingyMessage = domainEvent.AggregateEvent.ThingyMessage;
-            Id = thingyMessage.Id.Value;
-            Message = thingyMessage.Message;
-        }
+        var thingyMessage = domainEvent.AggregateEvent.ThingyMessage;
+        Id = thingyMessage.Id.Value;
+        Message = thingyMessage.Message;
+        return Task.CompletedTask;
+    }
 
-        public void Apply(IReadModelContext context, IDomainEvent<ThingyAggregate, ThingyId, ThingyMessageHistoryAddedEvent> domainEvent)
-        {
-            ThingyId = domainEvent.AggregateIdentity.Value;
+    public Task ApplyAsync(IReadModelContext context,
+        IDomainEvent<ThingyAggregate, ThingyId, ThingyMessageHistoryAddedEvent> domainEvent,
+        CancellationToken cancellationToken)
+    {
+        ThingyId = domainEvent.AggregateIdentity.Value;
 
-            var messageId = new ThingyMessageId(context.ReadModelId);
-            var thingyMessage = domainEvent.AggregateEvent.ThingyMessages.Single(m => m.Id == messageId);
-            Id = messageId.Value;
-            Message = thingyMessage.Message;
-        }
+        var messageId = new ThingyMessageId(context.ReadModelId);
+        var thingyMessage = domainEvent.AggregateEvent.ThingyMessages.Single(m => m.Id == messageId);
+        Id = messageId.Value;
+        Message = thingyMessage.Message;
+        return Task.CompletedTask;
+    }
 
-        public ThingyMessage ToThingyMessage()
-        {
-            return new ThingyMessage(
-                ThingyMessageId.With(Id),
-                Message);
-        }
+    public ThingyMessage ToThingyMessage()
+    {
+        return new ThingyMessage(
+            ThingyMessageId.With(Id),
+            Message);
     }
 }
diff --git a/Source/EventFlow.Elasticsearch.Tests/IntegrationTests/ReadModels/ElasticsearchThingyReadModel.cs b/Source/EventFlow.Elasticsearch.Tests/IntegrationTests/ReadModels/ElasticsearchThingyReadModel.cs
@@ -20,6 +20,8 @@
 // IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
 // CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
 
+using System.Threading;
+using System.Threading.Tasks;
 using EventFlow.Aggregates;
 using EventFlow.ReadStores;
 using EventFlow.TestHelpers.Aggregates;
@@ -49,21 +51,24 @@ public class ElasticsearchThingyReadModel : IReadModel,
             Index = false)]
         public int PingsReceived { get; set; }
 
-        public void Apply(IReadModelContext context, IDomainEvent<ThingyAggregate, ThingyId, ThingyDomainErrorAfterFirstEvent> domainEvent)
+        public Task ApplyAsync(IReadModelContext context, IDomainEvent<ThingyAggregate, ThingyId, ThingyDomainErrorAfterFirstEvent> domainEvent, CancellationToken cancellationToken)
         {
             Id = domainEvent.AggregateIdentity.Value;
             DomainErrorAfterFirstReceived = true;
+            return Task.CompletedTask;
         }
 
-        public void Apply(IReadModelContext context, IDomainEvent<ThingyAggregate, ThingyId, ThingyPingEvent> domainEvent)
+        public Task ApplyAsync(IReadModelContext context, IDomainEvent<ThingyAggregate, ThingyId, ThingyPingEvent> domainEvent, CancellationToken cancellationToken)
         {
             Id = domainEvent.AggregateIdentity.Value;
             PingsReceived++;
+            return Task.CompletedTask;
         }
 
-        public void Apply(IReadModelContext context, IDomainEvent<ThingyAggregate, ThingyId, ThingyDeletedEvent> domainEvent)
+        public Task ApplyAsync(IReadModelContext context, IDomainEvent<ThingyAggregate, ThingyId, ThingyDeletedEvent> domainEvent, CancellationToken cancellationToken)
         {
             context.MarkForDeletion();
+            return Task.CompletedTask;
         }
 
         public Thingy ToThingy()
diff --git a/Source/EventFlow.Elasticsearch/EventFlow.Elasticsearch.csproj b/Source/EventFlow.Elasticsearch/EventFlow.Elasticsearch.csproj
@@ -1,15 +1,14 @@
 ﻿<Project Sdk="Microsoft.NET.Sdk">
-  <Import Project="../Common.props" />
   <PropertyGroup>
-    <TargetFrameworks>netstandard2.0</TargetFrameworks>
+    <TargetFrameworks>netstandard2.1;netcoreapp3.1;net6.0;net8.0</TargetFrameworks>
     <TreatWarningsAsErrors>True</TreatWarningsAsErrors>
     <GenerateAssemblyInfo>True</GenerateAssemblyInfo>
     <GeneratePackageOnBuild>False</GeneratePackageOnBuild>
     <PackageRequireLicenseAcceptance>True</PackageRequireLicenseAcceptance>
     <Title>EventFlow.Elasticsearch</Title>
     <Authors>Rasmus Mikkelsen</Authors>
     <Company>Rasmus Mikkelsen</Company>
-    <Copyright>Copyright (c) Rasmus Mikkelsen 2015 - 2021</Copyright>
+    <Copyright>Copyright (c) Rasmus Mikkelsen 2015 - 2025</Copyright>
     <Description>Elasticsearch support for EventFlow</Description>
     <PackageTags>CQRS ES event sourcing Elasticsearch</PackageTags>
     <RepositoryType>git</RepositoryType>
diff --git a/Source/EventFlow.Elasticsearch/Extensions/EventFlowOptionsExtensions.cs b/Source/EventFlow.Elasticsearch/Extensions/EventFlowOptionsExtensions.cs
@@ -23,12 +23,10 @@
 using System;
 using System.Linq;
 using Elasticsearch.Net;
-using EventFlow.Aggregates;
-using EventFlow.Configuration;
-using EventFlow.Core;
 using EventFlow.Elasticsearch.ReadStores;
 using EventFlow.Extensions;
 using EventFlow.ReadStores;
+using Microsoft.Extensions.DependencyInjection;
 using Nest;
 
 namespace EventFlow.Elasticsearch.Extensions
@@ -70,8 +68,8 @@ public static IEventFlowOptions ConfigureElasticsearch(
         {
             return eventFlowOptions.RegisterServices(sr =>
                 {
-                    sr.Register(f => elasticClientFactory(), Lifetime.Singleton);
-                    sr.Register<IReadModelDescriptionProvider, ReadModelDescriptionProvider>(Lifetime.Singleton, true);
+                    sr.AddSingleton(_ => elasticClientFactory());
+                    sr.AddSingleton<IReadModelDescriptionProvider, ReadModelDescriptionProvider>();
                 });
         }
 
@@ -94,24 +92,11 @@ public static IEventFlowOptions UseElasticsearchReadModel<TReadModel, TReadModel
                 .UseReadStoreFor<IElasticsearchReadModelStore<TReadModel>, TReadModel, TReadModelLocator>();
         }
 
-        [Obsolete("Use the simpler method UseElasticsearchReadModel<TReadModel> instead.")]
-        public static IEventFlowOptions UseElasticsearchReadModelFor<TAggregate, TIdentity, TReadModel>(
-            this IEventFlowOptions eventFlowOptions)
-            where TAggregate : IAggregateRoot<TIdentity>
-            where TIdentity : IIdentity
-            where TReadModel : class, IReadModel
-        {
-            return eventFlowOptions
-                .RegisterServices(RegisterElasticsearchReadStore<TReadModel>)
-                .UseReadStoreFor<TAggregate, TIdentity, IElasticsearchReadModelStore<TReadModel>, TReadModel>();
-        }
-
-        private static void RegisterElasticsearchReadStore<TReadModel>(
-            IServiceRegistration serviceRegistration)
+        private static void RegisterElasticsearchReadStore<TReadModel>(IServiceCollection collection)
             where TReadModel : class, IReadModel
         {
-            serviceRegistration.Register<IElasticsearchReadModelStore<TReadModel>, ElasticsearchReadModelStore<TReadModel>>();
-            serviceRegistration.Register<IReadModelStore<TReadModel>>(r => r.Resolver.Resolve<IElasticsearchReadModelStore<TReadModel>>());
+            collection.AddTransient<IElasticsearchReadModelStore<TReadModel>, ElasticsearchReadModelStore<TReadModel>>();
+            collection.AddTransient<IReadModelStore<TReadModel>>(r => r.GetRequiredService<IElasticsearchReadModelStore<TReadModel>>());
         }
     }
 }
diff --git a/Source/EventFlow.Elasticsearch/ReadStores/ElasticsearchReadModelStore.cs b/Source/EventFlow.Elasticsearch/ReadStores/ElasticsearchReadModelStore.cs
@@ -32,8 +32,8 @@
 using EventFlow.Elasticsearch.ValueObjects;
 using EventFlow.Exceptions;
 using EventFlow.Extensions;
-using EventFlow.Logs;
 using EventFlow.ReadStores;
+using Microsoft.Extensions.Logging;
 using Nest;
 
 namespace EventFlow.Elasticsearch.ReadStores
@@ -42,13 +42,13 @@ public class ElasticsearchReadModelStore<TReadModel> :
         IElasticsearchReadModelStore<TReadModel>
         where TReadModel : class, IReadModel
     {
-        private readonly ILog _log;
+        private readonly ILogger<ElasticsearchReadModelStore<TReadModel>> _log;
         private readonly IElasticClient _elasticClient;
         private readonly IReadModelDescriptionProvider _readModelDescriptionProvider;
         private readonly ITransientFaultHandler<IOptimisticConcurrencyRetryStrategy> _transientFaultHandler;
 
         public ElasticsearchReadModelStore(
-            ILog log,
+            ILogger<ElasticsearchReadModelStore<TReadModel>> log,
             IElasticClient elasticClient,
             IReadModelDescriptionProvider readModelDescriptionProvider,
             ITransientFaultHandler<IOptimisticConcurrencyRetryStrategy> transientFaultHandler)
@@ -65,7 +65,7 @@ public async Task<ReadModelEnvelope<TReadModel>> GetAsync(
         {
             var readModelDescription = _readModelDescriptionProvider.GetReadModelDescription<TReadModel>();
 
-            _log.Verbose(() => $"Fetching read model '{typeof(TReadModel).PrettyPrint()}' with ID '{id}' from index '{readModelDescription.IndexName}'");
+            _log.LogTrace("Fetching read model '{TReadModel}' with ID '{Id}' from index '{IndexName}'", typeof(TReadModel).PrettyPrint(), id, readModelDescription.IndexName);
 
             var getResponse = await _elasticClient.GetAsync<TReadModel>(
                 id,
@@ -108,9 +108,10 @@ public async Task DeleteAllAsync(
         {
             var readModelDescription = _readModelDescriptionProvider.GetReadModelDescription<TReadModel>();
 
-            _log.Information($"Deleting ALL '{typeof(TReadModel).PrettyPrint()}' by DELETING INDEX '{readModelDescription.IndexName}'!");
+            _log.LogInformation("Deleting ALL '{TReadModel}' by DELETING INDEX '{IndexName}'!", typeof(TReadModel).PrettyPrint(), readModelDescription.IndexName);
 
-            var indices = _elasticClient.GetIndicesPointingToAlias(readModelDescription.IndexName.Value);
+            var indices = await _elasticClient.GetIndicesPointingToAliasAsync(readModelDescription.IndexName.Value)
+                .ConfigureAwait(false);
 
             foreach (var indexKey in indices)
             {

Original file line number	Diff line number	Diff line change
`@@ -1,4 +1,5 @@`
`1`	`1`	`### New in 1.2.0 (working version, not released yet)`
	`2`	+* New: NuGet `EventFlow.Elasticsearch` now ported to v1 (thanks @MMonrad)
`2`	`3`
`3`	`4`	* New: New NuGet package `EventFlow.SourceGenerators` created by @alexeyfv. See
`4`	`5`	`[documentation](https://geteventflow.net/additional/source-generation/) for details`
Original file line number	Diff line number	Diff line change
`@@ -20,6 +20,8 @@`
`20`	`20`	`// IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN`
`21`	`21`	`// CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.`
`22`	`22`
	`23`	`+using System.Threading;`
	`24`	`+using System.Threading.Tasks;`
`23`	`25`	`using EventFlow.Aggregates;`
`24`	`26`	`using EventFlow.ReadStores;`
`25`	`27`	`using EventFlow.TestHelpers.Aggregates;`
`@@ -49,21 +51,24 @@ public class ElasticsearchThingyReadModel : IReadModel,`
`49`	`51`	`Index = false)]`
`50`	`52`	`public int PingsReceived { get; set; }`
`51`	`53`
`52`		`- public void Apply(IReadModelContext context, IDomainEvent<ThingyAggregate, ThingyId, ThingyDomainErrorAfterFirstEvent> domainEvent)`
	`54`	`+ public Task ApplyAsync(IReadModelContext context, IDomainEvent<ThingyAggregate, ThingyId, ThingyDomainErrorAfterFirstEvent> domainEvent, CancellationToken cancellationToken)`
`53`	`55`	`{`
`54`	`56`	`Id = domainEvent.AggregateIdentity.Value;`
`55`	`57`	`DomainErrorAfterFirstReceived = true;`
	`58`	`+ return Task.CompletedTask;`
`56`	`59`	`}`
`57`	`60`
`58`		`- public void Apply(IReadModelContext context, IDomainEvent<ThingyAggregate, ThingyId, ThingyPingEvent> domainEvent)`
	`61`	`+ public Task ApplyAsync(IReadModelContext context, IDomainEvent<ThingyAggregate, ThingyId, ThingyPingEvent> domainEvent, CancellationToken cancellationToken)`
`59`	`62`	`{`
`60`	`63`	`Id = domainEvent.AggregateIdentity.Value;`
`61`	`64`	`PingsReceived++;`
	`65`	`+ return Task.CompletedTask;`
`62`	`66`	`}`
`63`	`67`
`64`		`- public void Apply(IReadModelContext context, IDomainEvent<ThingyAggregate, ThingyId, ThingyDeletedEvent> domainEvent)`
	`68`	`+ public Task ApplyAsync(IReadModelContext context, IDomainEvent<ThingyAggregate, ThingyId, ThingyDeletedEvent> domainEvent, CancellationToken cancellationToken)`
`65`	`69`	`{`
`66`	`70`	`context.MarkForDeletion();`
	`71`	`+ return Task.CompletedTask;`
`67`	`72`	`}`
`68`	`73`
`69`	`74`	`public Thingy ToThingy()`