TimeWarp.Mediator 13.0.0

TimeWarp Mediator

Simple, unambitious mediator implementation in .NET

In-process messaging with no dependencies.

Supports request/response, commands, queries, notifications and events, synchronous and async with intelligent dispatching via C# generic variance.

About This Fork

TimeWarp.Mediator is a fork of the excellent MediatR library by Jimmy Bogard. We created this fork to:

• ✅ Correct the spelling from "MediatR" to "Mediator"
• ✅ Release under The Unlicense for maximum freedom
• ✅ Maintain full API compatibility with MediatR
• ✅ Add helpful diagnostic tools like GetPipelineInfo()

Migration from MediatR

Migrating from MediatR is straightforward - see our migration guide for step-by-step instructions.

Original MediatR

Simple mediator implementation in .NET

In-process messaging with no dependencies.

Supports request/response, commands, queries, notifications and events, synchronous and async with intelligent dispatching via C# generic variance.

Examples in the wiki.

Installing TimeWarp.Mediator

You should install TimeWarp.Mediator with NuGet:

Install-Package TimeWarp.Mediator

Or via the .NET Core command line interface:

dotnet add package TimeWarp.Mediator

Either commands, from Package Manager Console or .NET Core CLI, will download and install TimeWarp.Mediator and all required dependencies.

Using Contracts-Only Package

To reference only the contracts for TimeWarp.Mediator, which includes:

• IRequest (including generic variants)
• INotification
• IStreamRequest

Add a package reference to TimeWarp.Mediator.Contracts

This package is useful in scenarios where your TimeWarp.Mediator contracts are in a separate assembly/project from handlers. Example scenarios include:

• API contracts
• GRPC contracts
• Blazor

Registering with IServiceCollection

TimeWarp.Mediator supports Microsoft.Extensions.DependencyInjection.Abstractions directly. To register various Mediator services and handlers:

services.AddMediator(cfg => cfg.RegisterServicesFromAssemblyContaining<Startup>());

or with an assembly:

services.AddMediator(cfg => cfg.RegisterServicesFromAssembly(typeof(Startup).Assembly));

This registers:

• IMediator as transient
• ISender as transient
• IPublisher as transient
• IRequestHandler<,> concrete implementations as transient
• IRequestHandler<> concrete implementations as transient
• INotificationHandler<> concrete implementations as transient
• IStreamRequestHandler<> concrete implementations as transient
• IRequestExceptionHandler<,,> concrete implementations as transient
• IRequestExceptionAction<,>) concrete implementations as transient

This also registers open generic implementations for:

• INotificationHandler<>
• IRequestExceptionHandler<,,>
• IRequestExceptionAction<,>

To register behaviors, stream behaviors, pre/post processors:

services.AddMediator(cfg => {
    cfg.RegisterServicesFromAssembly(typeof(Startup).Assembly);
    cfg.AddBehavior<PingPongBehavior>();
    cfg.AddStreamBehavior<PingPongStreamBehavior>();
    cfg.AddRequestPreProcessor<PingPreProcessor>();
    cfg.AddRequestPostProcessor<PingPongPostProcessor>();
    cfg.AddOpenBehavior(typeof(GenericBehavior<,>));
    });

With additional methods for open generics and overloads for explicit service types.

License

TimeWarp Mediator is released under The Unlicense (see UNLICENSE). Original MediatR code by Jimmy Bogard is under Apache 2.0 (see NOTICE).