Sha256: fdcf6c1c5881e7cf7076faa637eeccd66416aeba62407c509c7258db0a2ba58e
Contents?: true
Size: 786 Bytes
Versions: 2
Compression:
Stored size: 786 Bytes
Contents
require 'buftok' require 'http' require 'json' require 'twitter/error' module Twitter module Streaming class Response # Initializes a new Response object # # @return [Twitter::Streaming::Response] def initialize(&block) @block = block @parser = Http::Parser.new(self) @tokenizer = BufferedTokenizer.new("\r\n") end def <<(data) @parser << data end def on_headers_complete(_headers) error = Twitter::Error.errors[@parser.status_code] raise error.new if error end def on_body(data) @tokenizer.extract(data).each do |line| next if line.empty? @block.call(JSON.parse(line, symbolize_names: true)) end end end end end
Version data entries
2 entries across 2 versions & 1 rubygems
Version | Path |
---|---|
twitter-6.1.0 | lib/twitter/streaming/response.rb |
twitter-6.0.0 | lib/twitter/streaming/response.rb |