class Async::Wrapper

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