Uses of Class
com.google.common.util.concurrent.FluentFuture
Packages that use FluentFuture
-
Uses of FluentFuture in com.google.common.util.concurrent
Subclasses of FluentFuture in com.google.common.util.concurrentModifier and TypeClassDescription(package private) class
AbstractCatchingFuture<V,
X extends Throwable, F, T> Implementations ofFutures.catching*
.private static final class
AbstractCatchingFuture.AsyncCatchingFuture<V,
X extends Throwable> AnAbstractCatchingFuture
that delegates to anAsyncFunction
andAbstractFuture.setFuture(ListenableFuture)
.private static final class
AbstractCatchingFuture.CatchingFuture<V,
X extends Throwable> (package private) class
AbstractTransformFuture<I,
O, F, T> Implementations ofFutures.transform*
.private static final class
AnAbstractTransformFuture
that delegates to anAsyncFunction
andAbstractFuture.setFuture(ListenableFuture)
.private static final class
(package private) static class
A less abstract subclass of AbstractFuture.(package private) final class
FluentFuture
that forwards all calls to a delegate.(package private) final class
Implementation ofFutures#withTimeout
.(package private) class
ARunnableFuture
that also implements theListenableFuture
interface.Fields in com.google.common.util.concurrent declared as FluentFutureMethods in com.google.common.util.concurrent that return FluentFutureModifier and TypeMethodDescription(package private) <V,
U> FluentFuture <U> ClosingFuture.CloseableList.applyAsyncClosingFunction
(ClosingFuture.AsyncClosingFunction<V, U> transformation, V input) private <V> FluentFuture
<V> ClosingFuture.Peeker.callAsync
(ClosingFuture.Combiner.AsyncCombiningCallable<V> combiner, ClosingFuture.CloseableList closeables) final <X extends Throwable>
FluentFuture<V> FluentFuture.catching
(Class<X> exceptionType, Function<? super X, ? extends V> fallback, Executor executor) Returns aFuture
whose result is taken from thisFuture
or, if thisFuture
fails with the givenexceptionType
, from the result provided by thefallback
.final <X extends Throwable>
FluentFuture<V> FluentFuture.catchingAsync
(Class<X> exceptionType, AsyncFunction<? super X, ? extends V> fallback, Executor executor) Returns aFuture
whose result is taken from thisFuture
or, if thisFuture
fails with the givenexceptionType
, from the result provided by thefallback
.ClosingFuture.finishToFuture()
Marks this step as the last step in theClosingFuture
pipeline.static <V> FluentFuture
<V> FluentFuture.from
(FluentFuture<V> future) Deprecated.no need to use thisstatic <V> FluentFuture
<V> FluentFuture.from
(ListenableFuture<V> future) Converts the givenListenableFuture
to an equivalentFluentFuture
.final <T> FluentFuture
<T> Returns a newFuture
whose result is derived from the result of thisFuture
.final <T> FluentFuture
<T> FluentFuture.transformAsync
(AsyncFunction<? super V, T> function, Executor executor) Returns a newFuture
whose result is asynchronously derived from the result of thisFuture
.final FluentFuture
<V> FluentFuture.withTimeout
(long timeout, TimeUnit unit, ScheduledExecutorService scheduledExecutor) Returns a future that delegates to this future but will finish early (via aTimeoutException
wrapped in anExecutionException
) if the specified timeout expires.final FluentFuture
<V> FluentFuture.withTimeout
(Duration timeout, ScheduledExecutorService scheduledExecutor) Returns a future that delegates to this future but will finish early (via aTimeoutException
wrapped in anExecutionException
) if the specified timeout expires.Methods in com.google.common.util.concurrent that return types with arguments of type FluentFutureModifier and TypeMethodDescriptionprivate ImmutableList
<FluentFuture<?>> ClosingFuture.Combiner.inputFutures()
Methods in com.google.common.util.concurrent with parameters of type FluentFutureModifier and TypeMethodDescriptionprivate <U> ClosingFuture
<U> ClosingFuture.derive
(FluentFuture<U> future) static <V> FluentFuture
<V> FluentFuture.from
(FluentFuture<V> future) Deprecated.no need to use this