Orchestrix.Mediator 1.0.0

<p align="center"> <img src="logo.png" alt="Orchestrix.Mediator Logo" width="1024" /> </p>

🦖 Orchestrix.Mediator

Modern, extensible, and production-grade mediator engine for .NET 8+
With parallel notifications, streaming, pipelines, source generators, and full CQRS support via extensions.

✨ Why Orchestrix.Mediator?

Orchestrix.Mediator is a complete rethinking of a mediator engine for the modern .NET ecosystem.

✅ Reflection-based dispatch by default
🧬 Source generator dispatch (opt-in)
📢 Sequential & parallel notifications
📡 Streaming request handling (IAsyncEnumerable<T>)
🧱 Fully pluggable via pipelines and diagnostics hooks
🧩 CQRS-style ICommand, IQuery, and handler support (extension)
🔧 Minimal API & Controller friendly
🧪 Built for performance and testability

Full Documentation: Orchestrix.Mediator Docs →

📦 Installation

dotnet add package Orchestrix.Mediator

Optional Extensions

# Optional: Source generator-based dispatch
dotnet add package Orchestrix.Mediator.SourceGenerators

# Optional: CQRS abstractions (ICommand, IQuery, etc.)
dotnet add package Orchestrix.Mediator.Cqrs

🧰 Basic Example – Core Only

🧾 Define a request, notification, and handlers:

public record TestCommand(string? Name, string? Surname, string? Email, string? Phone) : IRequest<string>;

public class TestCommandHandler(IPublisher publisher) : IRequestHandler<TestCommand, string>
{
    public async ValueTask<string> Handle(TestCommand request, CancellationToken cancellationToken)
    {
        Console.WriteLine($"Hello {request.Name} {request.Surname} {request.Email} {request.Phone}");
        
        await publisher.Publish(new TestNotification(request.Name), cancellationToken);
        return "OK";
    }
}

public record TestNotification(string? Name) : INotification;

public class LogTestNotificationHandler : INotificationHandler<TestNotification>
{
    public ValueTask Handle(TestNotification notification, CancellationToken cancellationToken)
    {
        Console.WriteLine($"[Generic Handler] Logging TestNotification: {notification.Name}");
        return default;
    }
}

public class ParallelTestNotificationHandler : IParallelNotificationHandler<TestNotification>
{
    public async ValueTask Handle(TestNotification notification, CancellationToken cancellationToken)
    {
        Console.WriteLine($"[Parallel Handler] Simulating async work for {notification.Name}");
        await Task.Delay(300, cancellationToken);
    }
}

⚙️ Minimal API / Controller Example

[HttpGet]
public async Task<IActionResult> Test([FromServices] ISender sender)
{
    var command = new TestCommand("Mohammad", "Anzawi", "anzawi@test.com", "00000");
    var result = await sender.Send(command, CancellationToken.None);
    return Ok(result);
}

🔧 Configuration

Default (Reflection-based):

services.AddOrchestrix(cfg => cfg.RegisterHandlersFromAssemblies(typeof(SomeHandler).Assembly));

Enable Source Generator (opt-in):

services.AddOrchestrix(cfg => 
{
    cfg.UseSourceGenerator() // add this line
    .RegisterHandlersFromAssemblies(typeof(SomeHandler).Assembly);
});

🧬 Dispatch Modes

Source generators eliminate runtime lookup and boost performance.
See Source Generators →

✅ Core Interfaces

🧠 Diagnostics & Hooks

Enable diagnostics, logging, tracing, or global behaviors with zero impact on business logic.
See Hooks & Pipelines →

🧭 CQRS Extension

Install:

dotnet add package Orchestrix.Mediator.Cqrs

Adds:

// Marker interfaces
ICommand, ICommand<TResponse>
IQuery<TResponse>

// Handlers
ICommandHandler<T>, ICommandHandler<T, R>
IQueryHandler<T, R>

Supports both:

public class SaveCommand : ICommand;         // No return
public class SaveCommand : ICommand<Unit>;   // Explicit unit

See CQRS Guide →

📚 Documentation Index

Full Documentation: Orchestrix.Mediator Docs →

🔁 Migrating from MediatR?

See MIGRATION.md

• Swap IMediator to ISender and IPublisher
• Replace IRequestHandler<> with ICommandHandler<> / IQueryHandler<>
• Replace INotificationHandler<> with IParallelNotificationHandler<> if parallel behavior is needed
• Enable MediatorMode.SourceGenerator for performance
• Use Dispatch, DispatchVoid, TrySend, TryPublish, etc.

🚀 Performance-Ready

⚡ Zero-reflection dispatch via source generators
🧵 True parallel notifications
✅ ValueTask everywhere
🧬 NativeAOT-friendly
🔧 Small, fast, testable core

📜 License

MIT — free for personal and commercial use.

🙏 Acknowledgements

Inspired by MediatR
Rebuilt from scratch for modern .NET by @anzawi
Proudly open-source and forever free

🦖 Orchestrix.Mediator: Mediation, Modernized.