Function event_bus 

pub async fn event_bus(
    rx: Receiver<Event>,
    adapters: Vec<Arc<dyn ChannelAdapter>>,
    store: Arc<EventStore>,
    shutdown: CancellationToken,
) -> Result<(), Error>

Handles incoming events from the producer.

This function is responsible for receiving events from the producer and sending them to the appropriate adapters. It also handles the shutdown process and saves any pending logs to the event store.