EventBus.publish() should return a Promise about cqrs HOT 3 CLOSED

The implementation is based on RxJS streams. publish method is intended to be loosely coupled from subscribers and doesn't track whether every EventHandler failed or not.

from cqrs.

@kamilmysliwiec for systems where consistency is really important, it doesn't make sense not to have the ability to know whether or not the message has been received.

publish method is intended to be loosely coupled from subscribers

It it returns a Promise or a way to acknowledge the message has been successfully dispatched (i.e. actually stored in a message bus or, in the example of a synchronous event listener, actually handled) does not couple anything whatsoever, it just allows delivery guarantees.

from cqrs.

@sroze please, note that this library is just a lightweight implementation based on RxJS. Systems vary by requirements and hence, for more sophisticated scenarios, this library should be forked and tailored to the technical expectations of the project (if needed). CQRS and event-based systems is a huge topic and it's pretty much impossible for us to cover every single use-case and provide all possibly useful functionalities out-of-the-box.

from cqrs.