class Concurrent::Agent

def await_for!(timeout)

Raises:

(Concurrent::TimeoutError) - when timout is reached

Returns:

(Boolean) - true if all actions complete before timeout

Parameters:

timeout (Float) -- the maximum number of seconds to wait

def await_for!(timeout)
  raise Concurrent::TimeoutError unless wait(timeout.to_f)
  true
end