Contents

require "buftok"
require "http"
require "json"
require "twitter/error"
require "llhttp"

module Twitter
  module Streaming
    class Response
      # Initializes a new Response object
      #
      # @return [Twitter::Streaming::Response]
      def initialize(&block)
        @block     = block
        @parser    = LLHttp::Parser.new(self, type: :response)
        @tokenizer = BufferedTokenizer.new("\r\n")
      end

      def <<(data)
        @parser << data
      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

      def on_status(_status)
        error = Twitter::Error::ERRORS[@parser.status_code]
        raise error if error
      end
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
twitter-8.1.0	lib/twitter/streaming/response.rb
twitter-8.0.1	lib/twitter/streaming/response.rb
twitter-8.0.0	lib/twitter/streaming/response.rb
twitter-8.0.0.rc.1	lib/twitter/streaming/response.rb