Skip to content

Streaming and Parallel Event Processing

Choose a tag to compare

@vadikko2 vadikko2 released this 05 Dec 22:38
· 51 commits to master since this release
fccf7ac

πŸš€ New Features

Streaming Support & SSE

  1. StreamingRequestMediator: Added a new mediator designed for handling streaming requests that yield results incrementally.
  2. StreamingRequestHandler: Introduced a new handler type for processing large batches or long-running operations with real-time progress updates.
  3. FastAPI SSE Integration: Added native support and examples for using StreamingRequestMediator with Server-Sent Events (SSE) in FastAPI applications.

Parallel Event Processing

  1. Concurrent Event Handling: Both RequestMediator and StreamingRequestMediator now support processing domain events in parallel.
  2. Concurrency Control: Added max_concurrent_event_handlers parameter to limit the number of simultaneously running event handlers.
  3. Configuration: Added concurrent_event_handle_enable flag to toggle between sequential and parallel execution.

Dependency Injection

  1. dependency-injector Support: Added explicit support and documentation for the dependency-injector library using the DependencyInjectorCQRSContainer adapter.

πŸ“š Documentation

  1. Updated README with comprehensive examples for:
  2. Streaming Request Handlers.
  3. Parallel Event Processing configuration.
  4. FastAPI SSE implementation.
  5. DI container setup (both di and dependency-injector).