Method: Agent::Selector#timeout

Defined in:
lib/agent/selector.rb

#timeout(t, &blk) ⇒ Object 



39
40
41
42
43
 
# File 'lib/agent/selector.rb', line 39

def timeout(t, &blk)
  s = channel!(TrueClass, 1)
  go!{ sleep t; s.send(true); s.close }
  add_case(s, :timeout, &blk)
end