class Fluent::ObjectBufferedOutput

def emit(tag, es, chain) 

def emit(tag, es, chain)
  data = es.to_msgpack_stream
  key = tag
  if @buffer.emit(key, data, chain)
    submit_flush
  end
end

def initialize 

def initialize
  super
end

def write(chunk) 

def write(chunk)
  chunk.extend(BufferedEventStreamMixin)
  write_objects(chunk.key, chunk)
end