add query interface;

Author: dotnet9

src/CodeWF.EventBus/EventBus.Publish.cs

@@ -11,6 +11,12 @@ public void Publish<TCommand>(TCommand command) where TCommand : Command
             PublishAsync(command).GetAwaiter().GetResult();
         }
 
+        public T Query<T>(Query<T> query)
+        {
+            Publish(query);
+            return query.Result;
+        }
+
         public async Task PublishAsync<TCommand>(TCommand command) where TCommand : Command
         {
             if (_subscriptions.TryGetValue(typeof(TCommand), out var handlers))
@@ -28,5 +34,11 @@ public async Task PublishAsync<TCommand>(TCommand command) where TCommand : Comm
                 }
             }
         }
+
+        public async Task<T> QueryAsync<T>(Query<T> query)
+        {
+            await PublishAsync(query);
+            return query.Result;
+        }
     }
 }

src/CodeWF.EventBus/IEventBus.cs

@@ -15,6 +15,8 @@ public interface IEventBus
         void Unsubscribe<TCommand>(Action<TCommand> action) where TCommand : Command;
         void Unsubscribe<TCommand>(Func<TCommand, Task> asyncAction) where TCommand : Command;
         void Publish<TCommand>(TCommand command) where TCommand : Command;
+        T Query<T>(Query<T> query);
         Task PublishAsync<TCommand>(TCommand command) where TCommand : Command;
+        Task<T> QueryAsync<T>(Query<T> query);
     }
 }

src/Directory.Build.props

@@ -3,6 +3,6 @@
 		<BaseIntermediateOutputPath>$(MSBuildThisFileDirectory).vs\$(SolutionName)\Intermediate\$(MSBuildProjectName)\</BaseIntermediateOutputPath>
 		<OutputPath>$(MSBuildThisFileDirectory)\Output\</OutputPath>
 		<AppendTargetFrameworkToOutputPath>True</AppendTargetFrameworkToOutputPath>
-		<Version>3.3.1</Version>
+		<Version>3.4.0</Version>
 	</PropertyGroup>
 </Project>