class Fluent::Plugin::HttpInput

def parse_params_with_parser(params)
  if content = params[EVENT_RECORD_PARAMETER]
    @parser.parse(content) { |time, record|
      raise "Received event is not #{@format_name}: #{content}" if record.nil?
      return time, record
    }
  else
    raise "'#{EVENT_RECORD_PARAMETER}' parameter is required"
  end
end