class Fluent::StreamOutput::ReformatWriter
Public Class Methods
new(secondary)
click to toggle source
# File lib/fluent/plugin/out_stream.rb, line 60 def initialize(secondary) @secondary = secondary end
Public Instance Methods
write(chunk)
click to toggle source
# File lib/fluent/plugin/out_stream.rb, line 64 def write(chunk) chain = NullOutputChain.instance chunk.open {|io| # TODO use MessagePackIoEventStream u = MessagePack::Unpacker.new(io) begin u.each {|(tag,entries)| es = MultiEventStream.new entries.each {|o| es.add(o[0], o[1]) } @secondary.emit(tag, es, chain) } rescue EOFError end } end