M.EventBrokerSlim 1.0.0-preview3

EventBrokerSlim

An implementation of broadcasting events in a fire-and-forget style.

• in-memory, in-process
• publishing is Fire and Forget style
• events don't need to implement specific interface
• events are handled on a ThreadPool threads
• tightly integrated with Microsoft.Extensions.DependencyInjection
• each handler is resolved and runned in a new DI container scope

How does it work

Implement an event handler by implementing IEventHadler<TEvent> interface:

public record SomeEvent(string Message);

public class SomeEventHandler : IEventHandler<SomeEvent>
{
    // Inject services added to the DI container
    public SomeEventHandler()
    {
    }

    public async Task Handle(SomeEvent @event, CancellationToken cancellationToken)
    {
        // process the event
    }

    public Task OnError(Exception exception, SomeEvent @event, CancellationToken cancellationToken)
    {
        // called on unhandled exeption from Handle 
    }
}

Add event broker impelementation to DI container using AddEventBroker extension method and register handlers:

serviceCollection.AddEventBroker(
     x => x.AddKeyedTransient<SomeEvent, SomeEventHandler>());

Inject IEventBroker and publish events:

class MyClass
{
    private readonly IEventBroker _eventBroker;

    public MyClass(IEventBroker eventBroker)
    {
        _eventBroker = eventBroker;
    }
    
    public async Task DoSomething()
    {
        var someEvent = new SomeEvent("Something happened");
        await _eventBroker.Publish(someEvent);
    }
}