Method: Fluent::Plugin::JSONParser#parse_io

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

#parse_io(io, &block) ⇒ Object 



87
88
89
90
91
92
93
 
# File 'lib/fluent/plugin/parser_json.rb', line 87

def parse_io(io, &block)
  y = Yajl::Parser.new
  y.on_parse_complete = ->(record){
    block.call(parse_time(record), record)
  }
  y.parse(io, @stream_buffer_size)
end