Refactor: move MediatR types to EasyExtensions.Mediator

All MediatR interfaces, pipeline, and wrapper classes are moved to the new EasyExtensions.Mediator namespace and sub-namespaces. The NotificationHandlerExecutor record is replaced with a class. ServiceRegistrar is refactored for clarity and improved generic handler registration logic. Code formatting and documentation are updated for consistency. No functional changes are introduced; this is a structural and organizational refactor for maintainability.

Author: Vadim Belov

Sources/EasyExtensions.Mediator/IMediator.cs

@@ -1,8 +1,9 @@
-namespace MediatR;
-
-/// <summary>
-/// Defines a mediator to encapsulate request/response and publishing interaction patterns
-/// </summary>
-public interface IMediator : ISender, IPublisher
+namespace EasyExtensions.Mediator
 {
+    /// <summary>
+    /// Defines a mediator to encapsulate request/response and publishing interaction patterns
+    /// </summary>
+    public interface IMediator : ISender, IPublisher
+    {
+    }
 }

Sources/EasyExtensions.Mediator/INotificationHandler.cs

@@ -1,40 +1,41 @@
 using System.Threading;
 using System.Threading.Tasks;
 
-namespace MediatR;
-
-/// <summary>
-/// Defines a handler for a notification
-/// </summary>
-/// <typeparam name="TNotification">The type of notification being handled</typeparam>
-public interface INotificationHandler<in TNotification>
-    where TNotification : INotification
+namespace EasyExtensions.Mediator
 {
     /// <summary>
-    /// Handles a notification
+    /// Defines a handler for a notification
     /// </summary>
-    /// <param name="notification">The notification</param>
-    /// <param name="cancellationToken">Cancellation token</param>
-    Task Handle(TNotification notification, CancellationToken cancellationToken);
-}
-
-/// <summary>
-/// Wrapper class for a synchronous notification handler
-/// </summary>
-/// <typeparam name="TNotification">The notification type</typeparam>
-public abstract class NotificationHandler<TNotification> : INotificationHandler<TNotification>
+    /// <typeparam name="TNotification">The type of notification being handled</typeparam>
+    public interface INotificationHandler<in TNotification>
     where TNotification : INotification
-{
-    Task INotificationHandler<TNotification>.Handle(TNotification notification, CancellationToken cancellationToken)
     {
-        Handle(notification);
-
-        return Task.CompletedTask;
+        /// <summary>
+        /// Handles a notification
+        /// </summary>
+        /// <param name="notification">The notification</param>
+        /// <param name="cancellationToken">Cancellation token</param>
+        Task Handle(TNotification notification, CancellationToken cancellationToken);
     }
 
     /// <summary>
-    /// Override in a derived class for the handler logic
+    /// Wrapper class for a synchronous notification handler
     /// </summary>
-    /// <param name="notification">Notification</param>
-    protected abstract void Handle(TNotification notification);
+    /// <typeparam name="TNotification">The notification type</typeparam>
+    public abstract class NotificationHandler<TNotification> : INotificationHandler<TNotification>
+        where TNotification : INotification
+    {
+        Task INotificationHandler<TNotification>.Handle(TNotification notification, CancellationToken cancellationToken)
+        {
+            Handle(notification);
+
+            return Task.CompletedTask;
+        }
+
+        /// <summary>
+        /// Override in a derived class for the handler logic
+        /// </summary>
+        /// <param name="notification">Notification</param>
+        protected abstract void Handle(TNotification notification);
+    }
 }

Sources/EasyExtensions.Mediator/INotificationPublisher.cs

@@ -2,10 +2,11 @@
 using System.Threading.Tasks;
 using System.Threading;
 
-namespace MediatR;
-
-public interface INotificationPublisher
+namespace EasyExtensions.Mediator
 {
-    Task Publish(IEnumerable<NotificationHandlerExecutor> handlerExecutors, INotification notification,
-        CancellationToken cancellationToken);
+    public interface INotificationPublisher
+    {
+        Task Publish(IEnumerable<NotificationHandlerExecutor> handlerExecutors, INotification notification,
+            CancellationToken cancellationToken);
+    }
 }

Sources/EasyExtensions.Mediator/IPipelineBehavior.cs

@@ -1,30 +1,30 @@
-
-namespace MediatR;
-
 using System.Threading;
 using System.Threading.Tasks;
 
-/// <summary>
-/// Represents an async continuation for the next task to execute in the pipeline
-/// </summary>
-/// <typeparam name="TResponse">Response type</typeparam>
-/// <returns>Awaitable task returning a <typeparamref name="TResponse"/></returns>
-public delegate Task<TResponse> RequestHandlerDelegate<TResponse>(CancellationToken t = default);
-
-/// <summary>
-/// Pipeline behavior to surround the inner handler.
-/// Implementations add additional behavior and await the next delegate.
-/// </summary>
-/// <typeparam name="TRequest">Request type</typeparam>
-/// <typeparam name="TResponse">Response type</typeparam>
-public interface IPipelineBehavior<in TRequest, TResponse> where TRequest : notnull
+namespace EasyExtensions.Mediator
 {
     /// <summary>
-    /// Pipeline handler. Perform any additional behavior and await the <paramref name="next"/> delegate as necessary
+    /// Represents an async continuation for the next task to execute in the pipeline
+    /// </summary>
+    /// <typeparam name="TResponse">Response type</typeparam>
+    /// <returns>Awaitable task returning a <typeparamref name="TResponse"/></returns>
+    public delegate Task<TResponse> RequestHandlerDelegate<TResponse>(CancellationToken t = default);
+
+    /// <summary>
+    /// Pipeline behavior to surround the inner handler.
+    /// Implementations add additional behavior and await the next delegate.
     /// </summary>
-    /// <param name="request">Incoming request</param>
-    /// <param name="next">Awaitable delegate for the next action in the pipeline. Eventually this delegate represents the handler.</param>
-    /// <param name="cancellationToken">Cancellation token</param>
-    /// <returns>Awaitable task returning the <typeparamref name="TResponse"/></returns>
-    Task<TResponse> Handle(TRequest request, RequestHandlerDelegate<TResponse> next, CancellationToken cancellationToken);
+    /// <typeparam name="TRequest">Request type</typeparam>
+    /// <typeparam name="TResponse">Response type</typeparam>
+    public interface IPipelineBehavior<in TRequest, TResponse> where TRequest : notnull
+    {
+        /// <summary>
+        /// Pipeline handler. Perform any additional behavior and await the <paramref name="next"/> delegate as necessary
+        /// </summary>
+        /// <param name="request">Incoming request</param>
+        /// <param name="next">Awaitable delegate for the next action in the pipeline. Eventually this delegate represents the handler.</param>
+        /// <param name="cancellationToken">Cancellation token</param>
+        /// <returns>Awaitable task returning the <typeparamref name="TResponse"/></returns>
+        Task<TResponse> Handle(TRequest request, RequestHandlerDelegate<TResponse> next, CancellationToken cancellationToken);
+    }
 }

Sources/EasyExtensions.Mediator/IPublisher.cs

@@ -1,27 +1,28 @@
 using System.Threading;
 using System.Threading.Tasks;
 
-namespace MediatR;
-
-/// <summary>
-/// Publish a notification or event through the mediator pipeline to be handled by multiple handlers.
-/// </summary>
-public interface IPublisher
+namespace EasyExtensions.Mediator
 {
     /// <summary>
-    /// Asynchronously send a notification to multiple handlers
+    /// Publish a notification or event through the mediator pipeline to be handled by multiple handlers.
     /// </summary>
-    /// <param name="notification">Notification object</param>
-    /// <param name="cancellationToken">Optional cancellation token</param>
-    /// <returns>A task that represents the publish operation.</returns>
-    Task Publish(object notification, CancellationToken cancellationToken = default);
+    public interface IPublisher
+    {
+        /// <summary>
+        /// Asynchronously send a notification to multiple handlers
+        /// </summary>
+        /// <param name="notification">Notification object</param>
+        /// <param name="cancellationToken">Optional cancellation token</param>
+        /// <returns>A task that represents the publish operation.</returns>
+        Task Publish(object notification, CancellationToken cancellationToken = default);
 
-    /// <summary>
-    /// Asynchronously send a notification to multiple handlers
-    /// </summary>
-    /// <param name="notification">Notification object</param>
-    /// <param name="cancellationToken">Optional cancellation token</param>
-    /// <returns>A task that represents the publish operation.</returns>
-    Task Publish<TNotification>(TNotification notification, CancellationToken cancellationToken = default)
-        where TNotification : INotification;
+        /// <summary>
+        /// Asynchronously send a notification to multiple handlers
+        /// </summary>
+        /// <param name="notification">Notification object</param>
+        /// <param name="cancellationToken">Optional cancellation token</param>
+        /// <returns>A task that represents the publish operation.</returns>
+        Task Publish<TNotification>(TNotification notification, CancellationToken cancellationToken = default)
+            where TNotification : INotification;
+    }
 }

Sources/EasyExtensions.Mediator/IRequestHandler.cs

@@ -1,37 +1,38 @@
 using System.Threading;
 using System.Threading.Tasks;
 
-namespace MediatR;
-
-/// <summary>
-/// Defines a handler for a request
-/// </summary>
-/// <typeparam name="TRequest">The type of request being handled</typeparam>
-/// <typeparam name="TResponse">The type of response from the handler</typeparam>
-public interface IRequestHandler<in TRequest, TResponse>
-    where TRequest : IRequest<TResponse>
+namespace EasyExtensions.Mediator
 {
     /// <summary>
-    /// Handles a request
+    /// Defines a handler for a request
     /// </summary>
-    /// <param name="request">The request</param>
-    /// <param name="cancellationToken">Cancellation token</param>
-    /// <returns>Response from the request</returns>
-    Task<TResponse> Handle(TRequest request, CancellationToken cancellationToken);
-}
+    /// <typeparam name="TRequest">The type of request being handled</typeparam>
+    /// <typeparam name="TResponse">The type of response from the handler</typeparam>
+    public interface IRequestHandler<in TRequest, TResponse>
+    where TRequest : IRequest<TResponse>
+    {
+        /// <summary>
+        /// Handles a request
+        /// </summary>
+        /// <param name="request">The request</param>
+        /// <param name="cancellationToken">Cancellation token</param>
+        /// <returns>Response from the request</returns>
+        Task<TResponse> Handle(TRequest request, CancellationToken cancellationToken);
+    }
 
-/// <summary>
-/// Defines a handler for a request with a void response.
-/// </summary>
-/// <typeparam name="TRequest">The type of request being handled</typeparam>
-public interface IRequestHandler<in TRequest>
-    where TRequest : IRequest
-{
     /// <summary>
-    /// Handles a request
+    /// Defines a handler for a request with a void response.
     /// </summary>
-    /// <param name="request">The request</param>
-    /// <param name="cancellationToken">Cancellation token</param>
-    /// <returns>Response from the request</returns>
-    Task Handle(TRequest request, CancellationToken cancellationToken);
-}
+    /// <typeparam name="TRequest">The type of request being handled</typeparam>
+    public interface IRequestHandler<in TRequest>
+        where TRequest : IRequest
+    {
+        /// <summary>
+        /// Handles a request
+        /// </summary>
+        /// <param name="request">The request</param>
+        /// <param name="cancellationToken">Cancellation token</param>
+        /// <returns>Response from the request</returns>
+        Task Handle(TRequest request, CancellationToken cancellationToken);
+    }
+}

Sources/EasyExtensions.Mediator/ISender.cs

@@ -2,53 +2,54 @@
 using System.Threading;
 using System.Threading.Tasks;
 
-namespace MediatR;
-
-/// <summary>
-/// Send a request through the mediator pipeline to be handled by a single handler.
-/// </summary>
-public interface ISender
+namespace EasyExtensions.Mediator
 {
     /// <summary>
-    /// Asynchronously send a request to a single handler
+    /// Send a request through the mediator pipeline to be handled by a single handler.
     /// </summary>
-    /// <typeparam name="TResponse">Response type</typeparam>
-    /// <param name="request">Request object</param>
-    /// <param name="cancellationToken">Optional cancellation token</param>
-    /// <returns>A task that represents the send operation. The task result contains the handler response</returns>
-    Task<TResponse> Send<TResponse>(IRequest<TResponse> request, CancellationToken cancellationToken = default);
+    public interface ISender
+    {
+        /// <summary>
+        /// Asynchronously send a request to a single handler
+        /// </summary>
+        /// <typeparam name="TResponse">Response type</typeparam>
+        /// <param name="request">Request object</param>
+        /// <param name="cancellationToken">Optional cancellation token</param>
+        /// <returns>A task that represents the send operation. The task result contains the handler response</returns>
+        Task<TResponse> Send<TResponse>(IRequest<TResponse> request, CancellationToken cancellationToken = default);
 
-    /// <summary>
-    /// Asynchronously send a request to a single handler with no response
-    /// </summary>
-    /// <param name="request">Request object</param>
-    /// <param name="cancellationToken">Optional cancellation token</param>
-    /// <returns>A task that represents the send operation.</returns>
-    Task Send<TRequest>(TRequest request, CancellationToken cancellationToken = default)
-        where TRequest : IRequest;
+        /// <summary>
+        /// Asynchronously send a request to a single handler with no response
+        /// </summary>
+        /// <param name="request">Request object</param>
+        /// <param name="cancellationToken">Optional cancellation token</param>
+        /// <returns>A task that represents the send operation.</returns>
+        Task Send<TRequest>(TRequest request, CancellationToken cancellationToken = default)
+            where TRequest : IRequest;
 
-    /// <summary>
-    /// Asynchronously send an object request to a single handler via dynamic dispatch
-    /// </summary>
-    /// <param name="request">Request object</param>
-    /// <param name="cancellationToken">Optional cancellation token</param>
-    /// <returns>A task that represents the send operation. The task result contains the type erased handler response</returns>
-    Task<object?> Send(object request, CancellationToken cancellationToken = default);
+        /// <summary>
+        /// Asynchronously send an object request to a single handler via dynamic dispatch
+        /// </summary>
+        /// <param name="request">Request object</param>
+        /// <param name="cancellationToken">Optional cancellation token</param>
+        /// <returns>A task that represents the send operation. The task result contains the type erased handler response</returns>
+        Task<object?> Send(object request, CancellationToken cancellationToken = default);
 
-    /// <summary>
-    /// Create a stream via a single stream handler
-    /// </summary>
-    /// <typeparam name="TResponse"></typeparam>
-    /// <param name="request"></param>
-    /// <param name="cancellationToken"></param>
-    /// <returns></returns>
-    IAsyncEnumerable<TResponse> CreateStream<TResponse>(IStreamRequest<TResponse> request, CancellationToken cancellationToken = default);
+        /// <summary>
+        /// Create a stream via a single stream handler
+        /// </summary>
+        /// <typeparam name="TResponse"></typeparam>
+        /// <param name="request"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        IAsyncEnumerable<TResponse> CreateStream<TResponse>(IStreamRequest<TResponse> request, CancellationToken cancellationToken = default);
 
-    /// <summary>
-    /// Create a stream via an object request to a stream handler
-    /// </summary>
-    /// <param name="request"></param>
-    /// <param name="cancellationToken"></param>
-    /// <returns></returns>
-    IAsyncEnumerable<object?> CreateStream(object request, CancellationToken cancellationToken = default);
+        /// <summary>
+        /// Create a stream via an object request to a stream handler
+        /// </summary>
+        /// <param name="request"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        IAsyncEnumerable<object?> CreateStream(object request, CancellationToken cancellationToken = default);
+    }
 }