def acceptor = Mock(ConnectionAcceptor)
    // Use a shorter wait time before callback is called, so that we don't hit the 1 sec connection timeout
    def op = concurrent.waitsForAsyncCallback().withWaitTime(200)

    def startsChildProcessAndBlocksUntilConnectionEstablished() {
        when:
        workerProcess.setExecHandle(execHandle)
        workerProcess.startAccepting(acceptor)

        op.start {

    private Runnable callback
    private int waitTimeMillis = 500

    WaitForAsyncCallback(ConcurrentTestUtil owner) {
        super(owner)
    }

    WaitForAsyncCallback withWaitTime(int waitTimeMillis) {
        this.waitTimeMillis = waitTimeMillis
        return this
    }

    /**