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 |