# File lib/fluent/plugin/out_stream.rb, line 67 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
Generated with the Darkfish Rdoc Generator 2.