Method: Nervion::StreamParser#initialize

Defined in:
lib/nervion/stream_parser.rb

#initialize(parsers = {}) ⇒ StreamParser

Returns a new instance of StreamParser.



8
9
10
11
12
 
# File 'lib/nervion/stream_parser.rb', line 8

def initialize(parsers = {})
  @http_parser = parsers[:http_parser] || Http::Parser.new
  @json_parser = parsers[:json_parser] || Yajl::Parser.new(symbolize_keys: true)
  @http_parser.on_body = method(:process)
end