# File lib/plugins/user_stream.rb, line 28
    def process(&block)
      Termtter::Client.logger.info("connecting to UserStream")
      https = Net::HTTP.new(ENDPOINT.host, ENDPOINT.port)
      https.use_ssl = true
      https.verify_mode = OpenSSL::SSL::VERIFY_NONE

      https.start{ |https|
        request = Net::HTTP::Get.new(ENDPOINT.request_uri)
        request.oauth!(https, Termtter::API.twitter.access_token.consumer, Termtter::API.twitter.access_token)
        https.request(request){ |response|
          raise StandardError, response.code.to_i unless response.code.to_i == 200
          raise StandardError, 'Response is not chuncked' unless response.chunked?
          Termtter::Client.logger.info("connected to UserStream")
          response.read_body{ |chunk|
            Termtter::Client.logger.debug("received: #{chunk}")
            yield chunk
          }
        }
      }
    end