JKang.Events.InMemory 0.1.0

JKang.Events

A .NET Core ultra lightweight in-memory event bus implementation.

Sample:

1. Create an event implementing IEvent interface

    public class MessageSent : IEvent
    {
        public static MessageSent Create(string message)
        {
            return new MessageSent(Guid.NewGuid(), message);
        }

        private MessageSent(Guid eventId, string message)
        {
            EventId = eventId;
            Message = message;
        }

        public Guid EventId { get; }

        public string Message { get; }

2. Implement an event handler and register it IoC

    public class MessageSentEventHandler : IEventHandler<MessageSent>
    {
        public Task HandleEventAsync(MessageSent @event)
        {
            // consume the event here
            return Task.CompletedTask;
        }
    }

    // Startup.cs
    public void ConfigureServices(IServiceCollection services)
    {
        services
            .AddInMemoryEvents()
            .AddScoped<IEventHandler<MessageSent>, MessageSentEventHandler>()
            ;
    }

3. Publish the event

    var @event = MessageSent.Create("Hello world!");
    await _eventPublisher.PublishEventAsync(@event);

Any contributions or comments are welcome!