Class: HTTPX::Timers

Inherits:
Object
  • Object
show all
Defined in:
lib/httpx/timers.rb

Instance Method Summary collapse

Constructor Details

#initialize ⇒ Timers

Returns a new instance of Timers.



5
6
7
 
# File 'lib/httpx/timers.rb', line 5

def initialize
  @intervals = []
end

Instance Method Details

#after(interval_in_secs, &blk) ⇒ Object 



9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
 
# File 'lib/httpx/timers.rb', line 9

def after(interval_in_secs, &blk)
  return unless interval_in_secs

  # I'm assuming here that most requests will have the same
  # request timeout, as in most cases they share common set of
  # options. A user setting different request timeouts for 100s of
  # requests will already have a hard time dealing with that.
  unless (interval = @intervals.find { |t| t == interval_in_secs })
    interval = Interval.new(interval_in_secs)
    @intervals << interval
    @intervals.sort!
  end

  interval << blk
end

#cancel ⇒ Object 



42
43
44
 
# File 'lib/httpx/timers.rb', line 42

def cancel
  @intervals.clear
end

#fire(error = nil) ⇒ Object 



33
34
35
36
37
38
39
40
 
# File 'lib/httpx/timers.rb', line 33

def fire(error = nil)
  raise error if error && error.timeout != @intervals.first
  return if @intervals.empty? || !@next_interval_at

  elapsed_time = Utils.elapsed_time(@next_interval_at)

  @intervals.delete_if { |interval| interval.elapse(elapsed_time) <= 0 }
end

#wait_interval ⇒ Object 



25
26
27
28
29
30
31
 
# File 'lib/httpx/timers.rb', line 25

def wait_interval
  return if @intervals.empty?

  @next_interval_at = Utils.now

  @intervals.first.interval
end