Contents

module HTTPI
  module Adapter

    # = HTTPI::Adapter::NetHTTPPersistent
    #
    # Adapter for the Net::HTTP::Persistent client.
    # http://docs.seattlerb.org/net-http-persistent/Net/HTTP/Persistent.html
    class NetHTTPPersistent < NetHTTP

      register :net_http_persistent, :deps => %w(net/http/persistent)

      private

      def create_client
        if is_v3
          Net::HTTP::Persistent.new name: thread_key
        else
          Net::HTTP::Persistent.new thread_key
        end
      end

      def perform(http, http_request, &on_body)
        http.request @request.url, http_request, &on_body
      end

      def do_request(type, &requester)
        setup
        response = requester.call @client, request_client(type)
        respond_with(response)
      end

      def setup_client
        if @request.auth.ntlm?
          raise NotSupportedError, "Net::HTTP-Persistent does not support NTLM authentication"
        end

        @client.open_timeout = @request.open_timeout if @request.open_timeout
        @client.read_timeout = @request.read_timeout if @request.read_timeout
        raise NotSupportedError, "Net::HTTP::Persistent does not support write_timeout" if @request.write_timeout
      end

      def thread_key
        @request.url.host.split(/\W/).reject{|p|p == ""}.join('-')
      end

      def is_v3
        Net::HTTP::Persistent::VERSION.start_with? "3."
      end

    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
httpi-2.4.5	lib/httpi/adapter/net_http_persistent.rb