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