module ActiveSupport::Notifications::FanoutIteration

def iterate_guarding_exceptions(collection)
  exceptions = nil
  collection.each do |s|
    yield s
  rescue Exception => e
    exceptions ||= []
    exceptions << e
  end
  if exceptions
    exceptions = exceptions.flat_map do |exception|
      exception.is_a?(InstrumentationSubscriberError) ? exception.exceptions : [exception]
    end
    if exceptions.size == 1
      raise exceptions.first
    else
      raise InstrumentationSubscriberError.new(exceptions), cause: exceptions.first
    end
  end
  collection
end