class Dry::Events::Bus

def publish(event_id, payload)
  process(event_id, payload) do |event, listener|
    listener.(event)
  end
end