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, cb = nil, &blk) ⇒ Object 



9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
 
# File 'lib/httpx/timers.rb', line 9

def after(interval_in_secs, cb = nil, &blk)
  return unless interval_in_secs

  callback = cb || blk

  # 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 == interval_in_secs })
    interval = Interval.new(interval_in_secs)
    interval.on_empty { @intervals.delete(interval) }
    @intervals << interval
    @intervals.sort!
  end

  interval << callback

  @next_interval_at = nil

  interval
end

#fire(error = nil) ⇒ Object 



40
41
42
43
44
45
46
47
48
49
 
# File 'lib/httpx/timers.rb', line 40

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 = @intervals.drop_while { |interval| interval.elapse(elapsed_time) <= 0 }

  @next_interval_at = nil if @intervals.empty?
end

#wait_interval ⇒ Object 



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

def wait_interval
  return if @intervals.empty?

  @next_interval_at = Utils.now

  @intervals.first.interval
end