Object
# File lib/fluent/process.rb, line 223 def initialize(w) @w = w end
# File lib/fluent/process.rb, line 227 def emit(tag, es) ms = es.to_msgpack_stream #[tag, ms].to_msgpack(@w) # not thread safe @w.write [tag, ms].to_msgpack end
[Validate]
Generated with the Darkfish Rdoc Generator 2.