Sha256: a45a974635ed7460b095a7f51205a4311bdd473eb65b49239a852037a7a904ba
Contents?: true
Size: 1.18 KB
Versions: 18
Compression:
Stored size: 1.18 KB
Contents
require 'typhoeus'
module Acfs
module Adapter
# Adapter for Typhoeus.
#
class Typhoeus < Base
def start
hydra.run
rescue
@hydra = nil
raise
end
def abort
hydra.abort
end
def run(request)
convert_request(request).run
end
def queue(request)
hydra.queue convert_request request
end
protected
def hydra
@hydra ||= ::Typhoeus::Hydra.new
end
def convert_request(req)
request = ::Typhoeus::Request.new req.url,
method: req.method,
params: req.params,
headers: req.headers,
body: req.body
request.on_complete do |response|
req.complete! convert_response(req, response)
end
request
end
def convert_response(request, response)
Acfs::Response.new request,
status: response.code,
headers: response.headers,
body: response.body
end
end
end
end
Version data entries
18 entries across 18 versions & 1 rubygems