Merge pull request #844 from remcoros/patch-2

Use actual request type in new 'Send' method

src/MediatR/Mediator.cs

@@ -63,7 +63,7 @@ public Task Send<TRequest>(TRequest request, CancellationToken cancellationToken
             throw new ArgumentNullException(nameof(request));
         }
 
-        var requestType = typeof(TRequest);
+        var requestType = request.GetType();
 
         var handler = (RequestHandlerWrapper)_requestHandlers.GetOrAdd(requestType,
             static t => (RequestHandlerBase)(Activator.CreateInstance(typeof(RequestHandlerWrapperImpl<>).MakeGenericType(t))
@@ -207,4 +207,4 @@ public IAsyncEnumerable<TResponse> CreateStream<TResponse>(IStreamRequest<TRespo
 
         return items;
     }
-}
+}

test/MediatR.Tests/PublishTests.cs

@@ -215,8 +215,9 @@ public async Task Should_resolve_handlers_given_interface()
 
         var mediator = container.GetInstance<IMediator>();
 
-        INotification notification = new Ping { Message = "Ping" };
-        await mediator.Publish(notification);
+        // wrap notifications in an array, so this test won't break on a 'replace with var' refactoring
+        var notifications = new INotification[] { new Ping { Message = "Ping" } };
+        await mediator.Publish(notifications[0]);
 
         var result = builder.ToString().Split(new[] { Environment.NewLine }, StringSplitOptions.None);
         result.ShouldContain("Ping Pong");

test/MediatR.Tests/SendTests.cs

@@ -175,6 +175,31 @@ public async Task Should_resolve_main_handler_by_specific_interface()
         response.Message.ShouldBe("Ping Pong");
     }
 
+    [Fact]
+    public async Task Should_resolve_main_handler_by_given_interface()
+    {
+        var dependency = new Dependency();
+        var container = new Container(cfg =>
+        {
+            cfg.Scan(scanner =>
+            {
+                scanner.AssemblyContainingType(typeof(PublishTests));
+                scanner.IncludeNamespaceContainingType<VoidPing>();
+                scanner.WithDefaultConventions();
+                scanner.AddAllTypesOf(typeof(IRequestHandler<>));
+            });
+            cfg.ForSingletonOf<Dependency>().Use(dependency);
+            cfg.For<ISender>().Use<Mediator>();
+        });
+
+        var mediator = container.GetInstance<ISender>();
+
+        // wrap requests in an array, so this test won't break on a 'replace with var' refactoring
+        var requests = new IRequest[] { new VoidPing() };
+        await mediator.Send(requests[0]);
+
+        dependency.Called.ShouldBeTrue();
+    }
 
     [Fact]
     public async Task Should_raise_execption_on_null_request()