IQueryHandler & IQueryBus & QueryBus added

Author: aligholipour

Library/Query/IQueryBus.cs

@@ -0,0 +1,7 @@
+namespace Library.Query
+{
+    public interface IQueryBus
+    {
+        Task<TResponse> Dispatch<TRequest, TResponse>(TRequest command);
+    }
+}

Library/Query/IQueryHandler.cs

@@ -0,0 +1,7 @@
+namespace Library.Query
+{
+    public interface IQueryHandler<TRequest, TResponse>
+    {
+        Task<TResponse> Handle(TRequest command);
+    }
+}

Library/Query/QueryBus.cs

@@ -0,0 +1,19 @@
+using Microsoft.Extensions.DependencyInjection;
+
+namespace Library.Query
+{
+    public class QueryBus : IQueryBus
+    {
+        private readonly IServiceProvider _provider;
+        public QueryBus(IServiceProvider provider)
+        {
+            _provider = provider;
+        }
+
+        public async Task<TResponse> Dispatch<TRequest, TResponse>(TRequest query)
+        {
+            var service = _provider.GetRequiredService(typeof(IQueryHandler<TRequest, TResponse>)) as IQueryHandler<TRequest, TResponse>;
+            return await service.Handle(query);
+        }
+    }
+}