Class: Twitter::Streaming::Response
- Inherits:
-
Object
- Object
- Twitter::Streaming::Response
- Defined in:
- lib/twitter/streaming/response.rb
Instance Method Summary collapse
- #<<(data) ⇒ Object
-
#initialize(&block) ⇒ Twitter::Streaming::Response
constructor
Initializes a new Response object.
- #on_body(data) ⇒ Object
- #on_headers_complete(_headers) ⇒ Object
Constructor Details
#initialize(&block) ⇒ Twitter::Streaming::Response
Initializes a new Response object
12 13 14 15 16 |
# File 'lib/twitter/streaming/response.rb', line 12 def initialize(&block) @block = block @parser = Http::Parser.new(self) @tokenizer = BufferedTokenizer.new("\r\n") end |
Instance Method Details
#<<(data) ⇒ Object
18 19 20 |
# File 'lib/twitter/streaming/response.rb', line 18 def <<(data) @parser << data end |
#on_body(data) ⇒ Object
27 28 29 30 31 32 33 |
# File 'lib/twitter/streaming/response.rb', line 27 def on_body(data) @tokenizer.extract(data).each do |line| next if line.empty? @block.call(JSON.parse(line, symbolize_names: true)) end end |