class Dry::Events::Listener

def initialize(id)
  super()
  @id = id
  define_method(:subscribe) do |event_id, query = EMPTY_HASH, &block|
    Publisher.registry[id].subscribe(event_id, query, &block)
  end
end