- final ListenableFuture<Void> prepareFuture = Futures.transform(cohort.canCommit(), validateFunction);
- return Futures.transform(prepareFuture, prepareFunction);
+ final ListenableFuture<Void> prepareFuture = Futures.transformAsync(cohort.canCommit(), validateFunction,
+ MoreExecutors.directExecutor());
+ return Futures.transformAsync(prepareFuture, prepareFunction, MoreExecutors.directExecutor());