    # 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