class Async::Wrapper
def wait_any(timeout = nil)
-
duration
(Float
) -- timeout after the given duration if not `nil`.
def wait_any(timeout = nil) raise WaitError if @any self.reactor = Task.current.reactor begin @any = Fiber.current wait_for(timeout) ensure @any = nil @monitor.interests = interests if @monitor end end