Added StreamRequestHandler, NotificationHandler tests

Author: jithu7432

test/MediatR.DependencyInjectionTests/Abstractions/BaseAssemblyResolutionTests.cs

@@ -1,4 +1,6 @@
-using Microsoft.Extensions.DependencyInjection;
+using MediatR.DependencyInjectionTests.Contracts.Notifications;
+using MediatR.DependencyInjectionTests.Contracts.StreamRequests;
+using Microsoft.Extensions.DependencyInjection;
 
 namespace MediatR.DependencyInjectionTests.Abstractions;
 
@@ -14,8 +16,6 @@ public void Should_Resolve_Mediator() =>
         _provider.GetService<IMediator>()
             .ShouldNotBeNull();
 
-    #region REQUESTS
-
     [Fact]
     public void Should_Resolve_Public_RequestHandler() =>
         _provider.GetService<IRequestHandler<PublicPing, Pong>>()
@@ -31,10 +31,6 @@ public void Should_Resolve_Private_RequestHandler() =>
         _provider.GetService<IRequestHandler<PrivatePing, Pong>>()
             .ShouldNotBeNull();
 
-    #endregion
-
-    #region VOID_REQUESTS
-
     [Fact]
     public void Should_Resolve_Public_Void_RequestHandler() =>
         _provider.GetService<IRequestHandler<PublicVoidPing>>()
@@ -50,5 +46,24 @@ public void Should_Resolve_Private_Void_RequestHandler() =>
         _provider.GetService<IRequestHandler<PrivateVoidPing>>()
             .ShouldNotBeNull();
 
-    #endregion
+    [Fact]
+    public void Should_Resolve_Public_Private_Internal_Notification_Handlers() =>
+        _provider.GetServices<INotificationHandler<Ding>>()
+            .Count()
+            .ShouldBe(3);
+
+    [Fact]
+    public void Should_Resolve_Public_Stream_Request_Handlers() =>
+        _provider.GetService<IStreamRequestHandler<PublicZing, Zong>>()
+            .ShouldNotBeNull();
+
+    [Fact]
+    public void Should_Resolve_Internal_Stream_Request_Handlers() =>
+        _provider.GetService<IStreamRequestHandler<InternalZing, Zong>>()
+            .ShouldNotBeNull();
+
+    [Fact]
+    public void Should_Resolve_Private_Stream_Request_Handlers() =>
+        _provider.GetService<IStreamRequestHandler<PrivateZing, Zong>>()
+            .ShouldNotBeNull();
 }

test/MediatR.DependencyInjectionTests/Contracts/Notifications/Ding.cs

@@ -0,0 +1,22 @@
+namespace MediatR.DependencyInjectionTests.Contracts.Notifications;
+
+public record Ding : INotification
+{
+    public class Door1 : INotificationHandler<Ding>
+    {
+        public Task Handle(Ding notification, CancellationToken cancellationToken) =>
+            Task.CompletedTask;
+    }
+
+    internal class Door2 : INotificationHandler<Ding>
+    {
+        public Task Handle(Ding notification, CancellationToken cancellationToken) =>
+            Task.CompletedTask;
+    }
+
+    private class Door3 : INotificationHandler<Ding>
+    {
+        public Task Handle(Ding notification, CancellationToken cancellationToken) =>
+            Task.CompletedTask;
+    }
+}

test/MediatR.DependencyInjectionTests/Contracts/Responses/Pong.cs

@@ -1,3 +1,4 @@
 namespace MediatR.DependencyInjectionTests.Contracts.Responses;
 
-public record Pong;
+public record Pong;
+public record Zong;

test/MediatR.DependencyInjectionTests/Contracts/StreamRequests/InternalZing.cs

@@ -0,0 +1,10 @@
+namespace MediatR.DependencyInjectionTests.Contracts.StreamRequests;
+
+internal record InternalZing : IStreamRequest<Zong>
+{
+    internal class Handler : IStreamRequestHandler<InternalZing, Zong>
+    {
+        public IAsyncEnumerable<Zong> Handle(InternalZing request, CancellationToken token) =>
+            throw new NotImplementedException();
+    }
+}

test/MediatR.DependencyInjectionTests/Contracts/StreamRequests/PrivateZing.cs

@@ -0,0 +1,10 @@
+namespace MediatR.DependencyInjectionTests.Contracts.StreamRequests;
+
+internal record PrivateZing : IStreamRequest<Zong>
+{
+    private class Handler : IStreamRequestHandler<PrivateZing, Zong>
+    {
+        public IAsyncEnumerable<Zong> Handle(PrivateZing request, CancellationToken token) =>
+            throw new NotImplementedException();
+    }
+}

test/MediatR.DependencyInjectionTests/Contracts/StreamRequests/PublicZing.cs

@@ -0,0 +1,10 @@
+namespace MediatR.DependencyInjectionTests.Contracts.StreamRequests;
+
+public record PublicZing : IStreamRequest<Zong>
+{
+    public class Handler : IStreamRequestHandler<PublicZing, Zong>
+    {
+        public IAsyncEnumerable<Zong> Handle(PublicZing request, CancellationToken token) =>
+            throw new NotImplementedException();
+    }
+}