scheduling a callable for spacelift

gistfile1.java

  Tasks.prepare(CreateFileTask.class)
            .named("target/foobar")
            .then(DataSampler.class)
            .generateRandomData(123)
            .then(FileReader.class)
            .then(ExecutionCounter.class)
            .execute().awaitUntil(3, TimeUnit.SECONDS, new ExecutionCondition<Integer>() {
                @Override
                public boolean satisfiedBy(Integer object) throws ExecutionException {
                    return object >= 3;
                }
            });

        // restart counter
        Tasks.prepare(ExecutionCounter.class).restart();

        exception.expect(TimeoutExecutionException.class);

        Tasks.prepare(CreateFileTask.class)
            .named("target/foobar")
            .then(DataSampler.class)
            .generateRandomData(123)
            .then(FileReader.class)
            .then(ExecutionCounter.class)
            .execute()
            .pollEvery(1, TimeUnit.SECONDS).awaitUntil(3, TimeUnit.SECONDS, new ExecutionCondition<Integer>() {
                @Override
                public boolean satisfiedBy(Integer object) throws ExecutionException {
                    return object >= 5;
                }
            });