class Async::Wrapper

def wait_for(reactor, monitor, duration)
	# If the user requested an explicit timeout for this operation:
	if duration
		reactor.timeout(duration) do
			Task.yield
		end
	else
		Task.yield
	end
	
	return true
end