Uses of Class
com.google.common.util.concurrent.FluentFuture
-
Packages that use FluentFuture Package Description com.google.common.util.concurrent Concurrency utilities.com.google.common.util.concurrent.testing -
-
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>
class
AbstractFuture<V>
An abstract implementation ofListenableFuture
, intended for advanced users only.(package private) static class
AbstractFuture.TrustedFuture<V>
A less abstract subclass of AbstractFuture.(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) class
AggregateFuture<InputT,OutputT>
A future made up of a collection of sub-futures.(package private) class
CollectionFuture<V,C>
Aggregate future that collects (stores) results of each future.(package private) static class
CollectionFuture.ListFuture<V>
(package private) class
CombinedFuture<V>
Aggregate future that computes its value by calling a callable.(package private) class
ForwardingFluentFuture<V>
FluentFuture
that forwards all calls to a delegate.private static class
Futures.InCompletionOrderFuture<T>
private static class
Futures.NonCancellationPropagatingFuture<V>
A wrapped future that does not propagate cancellation to its delegate.(package private) class
ImmediateFuture<V>
Implementations ofFutures.immediate*
.(package private) static class
ImmediateFuture.ImmediateCancelledFuture<V>
(package private) static class
ImmediateFuture.ImmediateFailedCheckedFuture<V,X extends java.lang.Exception>
(package private) static class
ImmediateFuture.ImmediateFailedFuture<V>
(package private) static class
ImmediateFuture.ImmediateSuccessfulCheckedFuture<V,X extends java.lang.Exception>
(package private) static class
ImmediateFuture.ImmediateSuccessfulFuture<V>
private static class
MoreExecutors.ScheduledListeningDecorator.NeverSuccessfulListenableFutureTask
class
SettableFuture<V>
AListenableFuture
whose result can be set by aSettableFuture.set(Object)
,SettableFuture.setException(Throwable)
orSettableFuture.setFuture(ListenableFuture)
call.(package private) class
TimeoutFuture<V>
Implementation ofFutures#withTimeout
.(package private) class
TrustedListenableFutureTask<V>
ARunnableFuture
that also implements theListenableFuture
interface.Methods in com.google.common.util.concurrent that return FluentFuture Modifier and Type Method Description <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 the thisFuture
fails with the givenexceptionType
, from the result provided by thefallback
.static <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. -
Uses of FluentFuture in com.google.common.util.concurrent.testing
Subclasses of FluentFuture in com.google.common.util.concurrent.testing Modifier and Type Class Description private static class
TestingExecutors.NoOpScheduledExecutorService.NeverScheduledFuture<V>
-