mustafaturan/bus

🔊Minimalist message bus implementation for internal communication with zero-allocation magic on Emit

bus's Issues

Clarify Semantics

From the readme it's unclear how events are consumed. Will events always make it to all consumers? or can a consumer stop the processing? What is the order of processing of events? Is the order guaranteed? Would be great to clarify this.

How to setup the point of synchronization between consumers and producer?

I see this in example code:

// give some time to process events for async consumers
time.Sleep(time.Millisecond * 25)

This approach can not be use in production, Is there a more formal way to setup producer and consumers join point?

If there is one consumer, within Event.Data can use channel or something to synchronize, buf if with multiple consumers, this approach is not feasible.

Any suggestion?

[feature] Same topic support multiple handlers

Currently, one topic only support one handler, as code as:

handlers map[string]*Handler

but in some scenario, some topic need multiple handlers.