Contents

# encoding: utf-8

module Hatetepe
  # @see EM.heartbeat_interval
  class Client::Timeouts
    def initialize(config, _, connection)
      @config = config
      @connection = connection

      @config[:timeout]         ||= 2.0
      @config[:connect_timeout] ||= 2.0
    end

    def setup
      @connection.comm_inactivity_timeout = @config[:timeout]
      @connection.pending_connect_timeout = @config[:connect_timeout]
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
hatetepe-0.6.0.pre.1	lib/hatetepe/client/timeouts.rb