class Async::Wrapper

def wait_any(timeout = nil)

Parameters:
  • 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