Method: Fluent::StreamOutput#format_stream

Defined in:
lib/fluent/plugin/out_stream.rb

#format_stream(tag, es) ⇒ Object 



35
36
37
38
 
# File 'lib/fluent/plugin/out_stream.rb', line 35

def format_stream(tag, es)
  # use PackedForward
  [tag, es.to_msgpack_stream].to_msgpack
end