class Async::Wrapper

def wait_for(timeout)
	if @monitor
		@monitor.interests = interests
	else
		@monitor = @reactor.register(@io, interests, self)
	end
	
	# If the user requested an explicit timeout for this operation:
	if timeout
		@reactor.with_timeout(timeout) do
			Task.yield
		end
	else
		Task.yield
	end
	
	return true
end