- ListenableFuture<Void> submitFuture = writeTransaction.submit();
- return handleResultFuture(Futures.allAsList(submitFuture));
+ FluentFuture<?> submitFuture = writeTransaction.commit();
+ return Futures.transform(handleResultFuture(Futures.allAsList(submitFuture)), voidRpcResult -> {
+ if (voidRpcResult.isSuccessful()) {
+ return RpcResultBuilder.<AddFlowsDsOutput>success().build();
+ } else {
+ return RpcResultBuilder.<AddFlowsDsOutput>failed().build();
+ }
+ },MoreExecutors.directExecutor());