- final ListenableFuture<RpcResult<Void>> barrierResult = Futures.transform(input,
- new AsyncFunction<RpcResult<T>, RpcResult<Void>>() {
- @Override
- public ListenableFuture<RpcResult<Void>> apply(@Nullable final RpcResult<T> interInput) throws Exception {
- resultPair.setLeft(interInput);
- final SendBarrierInput barrierInput = createSendBarrierInput(nodeRef);
- return JdkFutureAdapters.listenInPoolThread(transactionService.sendBarrier(barrierInput));
- }
- });
+ final ListenableFuture<RpcResult<Void>> barrierResult = Futures.transformAsync(input,
+ interInput -> {
+ resultPair.setLeft(interInput);
+ final SendBarrierInput barrierInput = createSendBarrierInput(nodeRef);
+ return JdkFutureAdapters.listenInPoolThread(transactionService.sendBarrier(barrierInput));
+ }, MoreExecutors.directExecutor());