Searched refs:nonCancellationPropagating (Results 1 – 9 of 9) sorted by relevance
71 private final ListenableFuture<T> viewFuture = nonCancellationPropagating(future);116 private static <T> ListenableFuture<T> nonCancellationPropagating(ListenableFuture<T> future) { in nonCancellationPropagating() method in AbstractProducer
203 final ListenableFuture<T> outputFuture = Futures.nonCancellationPropagating(taskFuture);
33 import static com.google.common.util.concurrent.Futures.nonCancellationPropagating;409 final ClosingFuture<C> closingFuture = new ClosingFuture<>(nonCancellationPropagating(future)); in eventuallyClosing()583 return nonCancellationPropagating(future.transform(constant(null), directExecutor())); in statusFuture()
721 public static <V> ListenableFuture<V> nonCancellationPropagating(ListenableFuture<V> future) {
33 import static com.google.common.util.concurrent.Futures.nonCancellationPropagating;408 final ClosingFuture<C> closingFuture = new ClosingFuture<>(nonCancellationPropagating(future)); in eventuallyClosing()582 return nonCancellationPropagating(future.transform(constant(null), directExecutor())); in statusFuture()
754 public static <V> ListenableFuture<V> nonCancellationPropagating(ListenableFuture<V> future) {
37 import static com.google.common.util.concurrent.Futures.nonCancellationPropagating;3654 ListenableFuture<Foo> wrapper = nonCancellationPropagating(input);3665 ListenableFuture<Foo> wrapper = nonCancellationPropagating(input);3680 ListenableFuture<Foo> wrapper = nonCancellationPropagating(input);3689 ListenableFuture<Foo> wrapper = nonCancellationPropagating(input);