class Fluent::StreamOutput

def flush_secondary(secondary)
  unless secondary.is_a?(StreamOutput)
    secondary = ReformatWriter.new(secondary)
  end
  @buffer.pop(secondary)
end