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
9 10 11 12 13 |
# File 'lib/twitter/streaming/response.rb', line 9 def initialize(&block) @block = block @parser = Http::Parser.new(self) @tokenizer = BufferedTokenizer.new("\r\n") end |
Instance Method Details
#<<(data) ⇒ Object
15 16 17 |
# File 'lib/twitter/streaming/response.rb', line 15 def <<(data) @parser << data end |
#on_body(data) ⇒ Object
24 25 26 27 28 29 |
# File 'lib/twitter/streaming/response.rb', line 24 def on_body(data) @tokenizer.extract(data).each do |line| next if line.empty? @block.call(JSON.parse(line, :symbolize_names => true)) end end |