Sha256: 06c978eb115dca9f0b08b73d5433bdf7109532f1acff0d83bff0729849fe74ae
Contents?: true
Size: 1.08 KB
Versions: 7
Compression:
Stored size: 1.08 KB
Contents
require 'httpclient'
require 'rest-core/engine'
class RestCore::HttpClient < RestCore::Engine
private
def request promise, env
client = ::HTTPClient.new
client.cookie_manager = nil
client.follow_redirect_count = 0
client.transparent_gzip_decompression = true
payload, headers = payload_and_headers(env)
if env[HIJACK]
request_async(client, payload, headers, promise, env)
else
request_sync(client, payload, headers, promise, env)
end
end
def request_sync client, payload, headers, promise, env
res = client.request(env[REQUEST_METHOD], env[REQUEST_URI], nil,
payload, {'User-Agent' => 'Ruby'}.merge(headers))
promise.fulfill(res.content, res.status,
normalize_headers(res.header.all))
end
def request_async client, payload, headers, promise, env
res = client.request_async(env[REQUEST_METHOD], env[REQUEST_URI], nil,
payload, {'User-Agent' => 'Ruby'}.merge(headers)).pop
promise.fulfill('', res.status,
normalize_headers(res.header.all), res.content)
end
end
Version data entries
7 entries across 7 versions & 1 rubygems