From f55880306f674a72d6749867b9f08bf70233cc63 Mon Sep 17 00:00:00 2001
From: adimiko <amikolajczyk.it@gmail.com>
Date: Tue, 11 Mar 2025 19:18:10 +0100
Subject: [PATCH] Created AsyncScope in ModuleExecutor

---
 .../Databases/SampleAggragateRootRepository.cs             | 7 ++++++-
 source/EasyWay/Internals/Modules/ModuleExecutor.cs         | 6 +++---
 2 files changed, 9 insertions(+), 4 deletions(-)

diff --git a/samples/EasyWay.Samples/Databases/SampleAggragateRootRepository.cs b/samples/EasyWay.Samples/Databases/SampleAggragateRootRepository.cs
index 7501d6d..a934211 100644
--- a/samples/EasyWay.Samples/Databases/SampleAggragateRootRepository.cs
+++ b/samples/EasyWay.Samples/Databases/SampleAggragateRootRepository.cs
@@ -2,7 +2,7 @@
 
 namespace EasyWay.Samples.Databases
 {
-    public class SampleAggragateRootRepository : ISampleAggragateRootRepository
+    public class SampleAggragateRootRepository : ISampleAggragateRootRepository, IAsyncDisposable
     {
         private readonly IGenericRepository<SampleAggregateRoot> _repository;
 
@@ -16,6 +16,11 @@ public Task Add(SampleAggregateRoot aggregateRoot)
             return _repository.Add(aggregateRoot);
         }
 
+        public ValueTask DisposeAsync()
+        {
+            return ValueTask.CompletedTask;
+        }
+
         public Task<SampleAggregateRoot?> Get(Guid id)
         {
             return _repository.Get(id);
diff --git a/source/EasyWay/Internals/Modules/ModuleExecutor.cs b/source/EasyWay/Internals/Modules/ModuleExecutor.cs
index de4af31..f8ed950 100644
--- a/source/EasyWay/Internals/Modules/ModuleExecutor.cs
+++ b/source/EasyWay/Internals/Modules/ModuleExecutor.cs
@@ -19,7 +19,7 @@ public async Task<CommandResult> Command<TCommand>(TCommand command, Cancellatio
         {
             CommandResult commandResult;
 
-            using (var scope = _serviceProvider.CreateScope())
+            await using (var scope = _serviceProvider.CreateAsyncScope())
             {
                 var sp = scope.ServiceProvider;
 
@@ -37,7 +37,7 @@ public async Task<CommandResult<TOperationResult>> Command<TCommand, TOperationR
         {
             CommandResult<TOperationResult> commandResult;
 
-            using (var scope = _serviceProvider.CreateScope())
+            await using (var scope = _serviceProvider.CreateAsyncScope())
             {
                 var sp = scope.ServiceProvider;
 
@@ -55,7 +55,7 @@ public async Task<QueryResult<TReadModel>> Query<TQuery, TReadModel>(TQuery quer
         {
             QueryResult<TReadModel> result;
 
-            using (var scope = _serviceProvider.CreateScope())
+            await using (var scope = _serviceProvider.CreateAsyncScope())
             {
                 var sp = scope.ServiceProvider;