}

    def finished(int seconds) {
        if (!latch.await(seconds, TimeUnit.SECONDS)) {
            throw new AssertionError("Timeout waiting for operation to complete.")
        }
    }

    def failWithFailure() {
        if (failure) {
            throw UncheckedException.throwAsUncheckedException(BlockingResultHandler.attachCallerThreadStackTrace(failure))
        }
    }

    def assertNoFailure() {

            }
            assert !output.toString().contains(finishedMessage)
            sync.releaseAll()
            resultHandler.finished()
            resultHandler.failWithFailure()
        }

        then:
        output.toString().contains(waitingMessage)
        output.toString().contains(finishedMessage)
    }