*/
final class PingPongTransaction implements FutureCallback<CommitInfo> {
private final @NonNull SettableFuture<CommitInfo> future = SettableFuture.create();
- private final @NonNull FluentFuture<CommitInfo> fluent = FluentFuture.from(future);
+ private final @NonNull FluentFuture<CommitInfo> fluent =
+ FluentFuture.from(new UncancellableListenableFuture<>(future));
private final @NonNull DOMDataTreeReadWriteTransaction delegate;
private @Nullable DOMDataTreeReadWriteTransaction frontendTransaction;
return frontendTransaction;
}
- @NonNull FluentFuture<CommitInfo> getCommitFuture() {
+ @NonNull FluentFuture<? extends CommitInfo> completionFuture() {
return fluent;
}