class Async::Wrapper

def wait_any(duration = nil)
	raise WaitError if @any
	
	self.reactor = Task.current.reactor
	
	begin
		@any = Fiber.current
		wait_for(duration)
	ensure
		@any = nil
		@monitor.interests = interests if @monitor
	end
end