class ActiveSupport::Notifications::Fanout::BaseTimeGroup

def finish(name, id, payload)
  stop_time = now
  each do |listener|
    listener.call(name, @start_time, stop_time, id, payload)
  end
end