Method: Fluent::StreamOutput#flush_secondary

Defined in:
lib/fluent/plugin/out_stream.rb

#flush_secondary(secondary) ⇒ Object



55
56
57
58
59
60
# File 'lib/fluent/plugin/out_stream.rb', line 55

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