Unicorn for sleepy apps and slow clients

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
 # -*- encoding: binary -*-
# :enddoc:
# keep-alive timeout class
class Rainbows::Fiber::Rev::Kato < Rev::TimerWatcher
  def initialize
    @watch = []
    super(1, true)
  end

  def <<(fiber)
    @watch << fiber
    enable unless enabled?
  end

  def on_timer
    @watch.uniq!
    while f = @watch.shift
      f.resume if f.alive?
    end
    disable
  end
end