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) classAbstractCatchingFuture<V,X extends java.lang.Throwable,F,T>Implementations ofFutures.catching*.private static classAbstractCatchingFuture.AsyncCatchingFuture<V,X extends java.lang.Throwable>AnAbstractCatchingFuturethat delegates to anAsyncFunctionandAbstractFuture.setFuture(ListenableFuture).private static classAbstractCatchingFuture.CatchingFuture<V,X extends java.lang.Throwable>(package private) classAbstractTransformFuture<I,O,F,T>Implementations ofFutures.transform*.private static classAbstractTransformFuture.AsyncTransformFuture<I,O>AnAbstractTransformFuturethat delegates to anAsyncFunctionandAbstractFuture.setFuture(ListenableFuture).private static classAbstractTransformFuture.TransformFuture<I,O>(package private) static classFluentFuture.TrustedFuture<V>A less abstract subclass of AbstractFuture.(package private) classForwardingFluentFuture<V>FluentFuturethat forwards all calls to a delegate.(package private) classTimeoutFuture<V>Implementation ofFutures#withTimeout.(package private) classTrustedListenableFutureTask<V>ARunnableFuturethat also implements theListenableFutureinterface.Fields in com.google.common.util.concurrent declared as FluentFuture Modifier and Type Field Description private FluentFuture<V>ClosingFuture. futureFields 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_FUTUREMethods 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 aFuturewhose result is taken from thisFutureor, if thisFuturefails 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 aFuturewhose result is taken from thisFutureor, if thisFuturefails with the givenexceptionType, from the result provided by thefallback.FluentFuture<V>ClosingFuture. finishToFuture()Marks this step as the last step in theClosingFuturepipeline.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 givenListenableFutureto an equivalentFluentFuture.<T> FluentFuture<T>FluentFuture. transform(Function<? super V,T> function, java.util.concurrent.Executor executor)Returns a newFuturewhose 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 newFuturewhose 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 aTimeoutExceptionwrapped 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 aTimeoutExceptionwrapped 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
-