Object
# File lib/fluent/process.rb, line 225 def initialize(w) @w = w end
# File lib/fluent/process.rb, line 229 def emit(tag, es) ms = es.to_msgpack_stream #[tag, ms].to_msgpack(@w) # not thread safe @w.write [tag, ms].to_msgpack end