class ActiveSupport::Notifications::Fanout::BaseGroup

def each(&block)
  iterate_guarding_exceptions(@listeners, &block)
end

def initialize(listeners, name, id, payload)
  @listeners = listeners
end