Contents

# frozen_string_literal: true

class EzClient::PersistentClient
  extend Forwardable

  def_delegators :http_client, :build_request, :default_options, :timeout

  def initialize(origin, keep_alive_timeout)
    self.origin = origin
    self.keep_alive_timeout = keep_alive_timeout
    self.last_request_at = nil
  end

  def perform(*args)
    http_client.perform(*args).tap do
      self.last_request_at = EzClient.get_time
    end
  end

  def timed_out?
    last_request_at && EzClient.get_time - last_request_at >= keep_alive_timeout
  end

  private

  attr_accessor :origin, :keep_alive_timeout, :last_request_at

  def http_client
    @http_client ||= HTTP.persistent(origin, timeout: keep_alive_timeout)
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
ezclient-1.7.1	lib/ezclient/persistent_client.rb
ezclient-1.7.0	lib/ezclient/persistent_client.rb
ezclient-1.6.0	lib/ezclient/persistent_client.rb
ezclient-1.5.1	lib/ezclient/persistent_client.rb