class Dry::Events::Bus

def process(event_id, payload)
  listeners[event_id].each do |listener, filter|
    event = events[event_id].payload(payload)
    if filter.(payload)
      yield(event, listener)
    end
  end
end