EventFlux 1.1.5

EventFlux

EventFlux is a lightweight, event-driven event handler library for .NET 8.0.
EventFlux is a lightweight, event-driven event handler library for .NET 8.0. It provides a simple way to trigger multiple events and handle them efficiently

Features

• Event-Based Architecture: Easily trigger and handle multiple events.
• Automatic Event Handler Discovery: Scans assemblies and registers handlers automatically.
• Lightweight & High Performance: Built for .NET 8.0 applications.
• Deferred Event Execution: Collect events in a list and trigger them all at once for optimized processing and better control over execution flow.
• Multiple Event Handlers Support: A single event can trigger multiple handlers.
• Pipeline Behaviors Support: Add custom middleware like logging, validation, and caching to the event processing pipeline.
• Dynamic Event Dispatching: Route events dynamically to different handlers.

Installation

You can install EventFlux via NuGet Package Manager:

Injection

var builder = WebApplication.CreateBuilder(args);

// optionals
//builder.Services.AddEventLogging();
//builder.Services.AddEventTimeout();
builder.Services.AddEventBus(AssemblyReference.Assemblies).AddEventLogging().AddEventTimeout();

builder.Services.AddEventDispatcher();

var app = builder.Build();
app.Run();

Use Example

 public class ExampleController(IEventBus _eventBus) : ControllerBase
 {
     [HttpPost("create-user")]
     public async Task<IActionResult> CreateUser([FromBody] CreateUserCommandRequest command)
     {
         CreateUserCommandResponse response = await _eventBus.SendAsync(command);
         return Ok(response);
     }

 }

Use Event Dispatcher

   public class ValidationBehavior<TRequest, TResponse>: IEventCustomPipeline<TRequest, TResponse>
       where TRequest : IEventRequest<TResponse>
       where TResponse : IEventResponse
   {
       public async Task<TResponse> Handle(
           TRequest request,
           EventHandlerDelegate<TResponse> next,
           CancellationToken cancellationToken)
       {
           Console.WriteLine($"Validating {typeof(TRequest).Name}");
           return await next();
       }
   }

Use Example

 public class ExampleController(IEventDispatcher _eventDispatcher) : ControllerBase
 {
  [HttpPost("update-user")]
  public async Task<IActionResult> UpdateUser([FromBody] UpdateUserCommandRequest command)
  {
      UpdateUserCommandResponse response = await _eventDispatcher.SendAsync(command);
      return Ok(response);
  }

 }