Uses of Class
com.google.common.util.concurrent.FluentFuture
-
Packages that use FluentFuture Package Description com.google.common.util.concurrent Concurrency utilities. -
-
Uses of FluentFuture in com.google.common.util.concurrent
Subclasses of FluentFuture in com.google.common.util.concurrent Modifier and Type Class Description (package private) class
AbstractCatchingFuture<V,X extends java.lang.Throwable,F,T>
Implementations ofFutures.catching*
.private static class
AbstractCatchingFuture.AsyncCatchingFuture<V,X extends java.lang.Throwable>
AnAbstractCatchingFuture
that delegates to anAsyncFunction
andAbstractFuture.setFuture(ListenableFuture)
.private static class
AbstractCatchingFuture.CatchingFuture<V,X extends java.lang.Throwable>
(package private) class
AbstractTransformFuture<I,O,F,T>
Implementations ofFutures.transform*
.private static class
AbstractTransformFuture.AsyncTransformFuture<I,O>
AnAbstractTransformFuture
that delegates to anAsyncFunction
andAbstractFuture.setFuture(ListenableFuture)
.private static class
AbstractTransformFuture.TransformFuture<I,O>
(package private) static class
FluentFuture.TrustedFuture<V>
A less abstract subclass of AbstractFuture.(package private) class
ForwardingFluentFuture<V>
FluentFuture
that forwards all calls to a delegate.(package private) class
TimeoutFuture<V>
Implementation ofFutures#withTimeout
.(package private) class
TrustedListenableFutureTask<V>
ARunnableFuture
that also implements theListenableFuture
interface.Fields in com.google.common.util.concurrent declared as FluentFuture Modifier and Type Field Description private FluentFuture<V>
ClosingFuture. future
Fields in com.google.common.util.concurrent with type parameters of type FluentFuture Modifier and Type Field Description private static Function<ClosingFuture<?>,FluentFuture<?>>
ClosingFuture.Combiner. INNER_FUTURE
Methods in com.google.common.util.concurrent that return FluentFuture Modifier and Type Method Description (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)
<X extends java.lang.Throwable>
FluentFuture<V>FluentFuture. catching(java.lang.Class<X> exceptionType, Function<? super X,? extends V> fallback, java.util.concurrent.Executor executor)
Returns aFuture
whose result is taken from thisFuture
or, if thisFuture
fails with the givenexceptionType
, from the result provided by thefallback
.<X extends java.lang.Throwable>
FluentFuture<V>FluentFuture. catchingAsync(java.lang.Class<X> exceptionType, AsyncFunction<? super X,? extends V> fallback, java.util.concurrent.Executor executor)
Returns aFuture
whose result is taken from thisFuture
or, if thisFuture
fails with the givenexceptionType
, from the result provided by thefallback
.FluentFuture<V>
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
.<T> FluentFuture<T>
FluentFuture. transform(Function<? super V,T> function, java.util.concurrent.Executor executor)
Returns a newFuture
whose result is derived from the result of thisFuture
.<T> FluentFuture<T>
FluentFuture. transformAsync(AsyncFunction<? super V,T> function, java.util.concurrent.Executor executor)
Returns a newFuture
whose result is asynchronously derived from the result of thisFuture
.FluentFuture<V>
FluentFuture. withTimeout(long timeout, java.util.concurrent.TimeUnit unit, java.util.concurrent.ScheduledExecutorService scheduledExecutor)
Returns a future that delegates to this future but will finish early (via aTimeoutException
wrapped in anExecutionException
) if the specified timeout expires.FluentFuture<V>
FluentFuture. withTimeout(java.time.Duration timeout, java.util.concurrent.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 FluentFuture Modifier and Type Method Description private ImmutableList<FluentFuture<?>>
ClosingFuture.Combiner. inputFutures()
Methods in com.google.common.util.concurrent with parameters of type FluentFuture Modifier and Type Method Description private <U> ClosingFuture<U>
ClosingFuture. derive(FluentFuture<U> future)
static <V> FluentFuture<V>
FluentFuture. from(FluentFuture<V> future)
Deprecated.no need to use this
-