Uses of Class
com.google.common.util.concurrent.ClosingFuture
Packages that use ClosingFuture
-
Uses of ClosingFuture in com.google.common.util.concurrent
Fields in com.google.common.util.concurrent declared as ClosingFutureModifier and TypeFieldDescriptionprivate final ClosingFuture<? extends V>ClosingFuture.ValueAndCloser.closingFutureprivate final ClosingFuture<V1>ClosingFuture.Combiner2.future1private final ClosingFuture<V1>ClosingFuture.Combiner3.future1private final ClosingFuture<V1>ClosingFuture.Combiner4.future1private final ClosingFuture<V1>ClosingFuture.Combiner5.future1private final ClosingFuture<V2>ClosingFuture.Combiner2.future2private final ClosingFuture<V2>ClosingFuture.Combiner3.future2private final ClosingFuture<V2>ClosingFuture.Combiner4.future2private final ClosingFuture<V2>ClosingFuture.Combiner5.future2private final ClosingFuture<V3>ClosingFuture.Combiner3.future3private final ClosingFuture<V3>ClosingFuture.Combiner4.future3private final ClosingFuture<V3>ClosingFuture.Combiner5.future3private final ClosingFuture<V4>ClosingFuture.Combiner4.future4private final ClosingFuture<V4>ClosingFuture.Combiner5.future4private final ClosingFuture<V5>ClosingFuture.Combiner5.future5Fields in com.google.common.util.concurrent with type parameters of type ClosingFutureModifier and TypeFieldDescriptionprivate final ImmutableList<ClosingFuture<?>>ClosingFuture.Peeker.futuresprotected final ImmutableList<ClosingFuture<?>>ClosingFuture.Combiner.inputsMethods in com.google.common.util.concurrent that return ClosingFutureModifier and TypeMethodDescriptionClosingFuture.AsyncClosingFunction.apply(ClosingFuture.DeferredCloser closer, T input) Applies this function to an input, or throws an exception if unable to do so.ClosingFuture.Combiner2.AsyncClosingFunction2.apply(ClosingFuture.DeferredCloser closer, V1 value1, V2 value2) Applies this function to two inputs, or throws an exception if unable to do so.ClosingFuture.Combiner3.AsyncClosingFunction3.apply(ClosingFuture.DeferredCloser closer, V1 value1, V2 value2, V3 value3) Applies this function to three inputs, or throws an exception if unable to do so.ClosingFuture.Combiner4.AsyncClosingFunction4.apply(ClosingFuture.DeferredCloser closer, V1 value1, V2 value2, V3 value3, V4 value4) Applies this function to four inputs, or throws an exception if unable to do so.ClosingFuture.Combiner5.AsyncClosingFunction5.apply(ClosingFuture.DeferredCloser closer, V1 value1, V2 value2, V3 value3, V4 value4, V5 value5) Applies this function to five inputs, or throws an exception if unable to do so.ClosingFuture.AsyncClosingCallable.call(ClosingFuture.DeferredCloser closer) Computes a result, or throws an exception if unable to do so.ClosingFuture.Combiner.AsyncCombiningCallable.call(ClosingFuture.DeferredCloser closer, ClosingFuture.Peeker peeker) Computes aClosingFutureresult, or throws an exception if unable to do so.<V> ClosingFuture<V>ClosingFuture.Combiner.call(ClosingFuture.Combiner.CombiningCallable<V> combiningCallable, Executor executor) Returns a newClosingFuturepipeline step derived from the inputs by applying a combining function to their values.<U> ClosingFuture<U>ClosingFuture.Combiner2.call(ClosingFuture.Combiner2.ClosingFunction2<V1, V2, U> function, Executor executor) Returns a newClosingFuturepipeline step derived from the inputs by applying a combining function to their values.<U> ClosingFuture<U>ClosingFuture.Combiner3.call(ClosingFuture.Combiner3.ClosingFunction3<V1, V2, V3, U> function, Executor executor) Returns a newClosingFuturepipeline step derived from the inputs by applying a combining function to their values.<U> ClosingFuture<U>ClosingFuture.Combiner4.call(ClosingFuture.Combiner4.ClosingFunction4<V1, V2, V3, V4, U> function, Executor executor) Returns a newClosingFuturepipeline step derived from the inputs by applying a combining function to their values.<U> ClosingFuture<U>ClosingFuture.Combiner5.call(ClosingFuture.Combiner5.ClosingFunction5<V1, V2, V3, V4, V5, U> function, Executor executor) Returns a newClosingFuturepipeline step derived from the inputs by applying a combining function to their values.<V> ClosingFuture<V>ClosingFuture.Combiner.callAsync(ClosingFuture.Combiner.AsyncCombiningCallable<V> combiningCallable, Executor executor) Returns a newClosingFuturepipeline step derived from the inputs by applying aClosingFuture-returning function to their values.<U> ClosingFuture<U>ClosingFuture.Combiner2.callAsync(ClosingFuture.Combiner2.AsyncClosingFunction2<V1, V2, U> function, Executor executor) Returns a newClosingFuturepipeline step derived from the inputs by applying aClosingFuture-returning function to their values.<U> ClosingFuture<U>ClosingFuture.Combiner3.callAsync(ClosingFuture.Combiner3.AsyncClosingFunction3<V1, V2, V3, U> function, Executor executor) Returns a newClosingFuturepipeline step derived from the inputs by applying aClosingFuture-returning function to their values.<U> ClosingFuture<U>ClosingFuture.Combiner4.callAsync(ClosingFuture.Combiner4.AsyncClosingFunction4<V1, V2, V3, V4, U> function, Executor executor) Returns a newClosingFuturepipeline step derived from the inputs by applying aClosingFuture-returning function to their values.<U> ClosingFuture<U>ClosingFuture.Combiner5.callAsync(ClosingFuture.Combiner5.AsyncClosingFunction5<V1, V2, V3, V4, V5, U> function, Executor executor) Returns a newClosingFuturepipeline step derived from the inputs by applying aClosingFuture-returning function to their values.<X extends Throwable>
ClosingFuture<V>ClosingFuture.catching(Class<X> exceptionType, ClosingFuture.ClosingFunction<? super X, ? extends V> fallback, Executor executor) Returns a newClosingFuturepipeline step derived from this one by applying a function to its exception if it is an instance of a given exception type.<X extends Throwable>
ClosingFuture<V>ClosingFuture.catchingAsync(Class<X> exceptionType, ClosingFuture.AsyncClosingFunction<? super X, ? extends V> fallback, Executor executor) Returns a newClosingFuturepipeline step derived from this one by applying a function that returns aClosingFutureto its exception if it is an instance of a given exception type.private <X extends Throwable,W extends V>
ClosingFuture<V>ClosingFuture.catchingAsyncMoreGeneric(Class<X> exceptionType, ClosingFuture.AsyncClosingFunction<? super X, W> fallback, Executor executor) private <X extends Throwable,W extends V>
ClosingFuture<V>ClosingFuture.catchingMoreGeneric(Class<X> exceptionType, ClosingFuture.ClosingFunction<? super X, W> fallback, Executor executor) private <U> ClosingFuture<U>ClosingFuture.derive(FluentFuture<U> future) static <C extends Object & AutoCloseable>
ClosingFuture<C>ClosingFuture.eventuallyClosing(ListenableFuture<C> future, Executor closingExecutor) Deprecated.static <V> ClosingFuture<V>ClosingFuture.from(ListenableFuture<V> future) Starts aClosingFuturepipeline with aListenableFuture.static <V> ClosingFuture<V>ClosingFuture.submit(ClosingFuture.ClosingCallable<V> callable, Executor executor) Starts aClosingFuturepipeline by submitting a callable block to an executor.static <V> ClosingFuture<V>ClosingFuture.submitAsync(ClosingFuture.AsyncClosingCallable<V> callable, Executor executor) Starts aClosingFuturepipeline by submitting a callable block to an executor.<U> ClosingFuture<U>ClosingFuture.transform(ClosingFuture.ClosingFunction<? super V, U> function, Executor executor) Returns a newClosingFuturepipeline step derived from this one by applying a function to its value.<U> ClosingFuture<U>ClosingFuture.transformAsync(ClosingFuture.AsyncClosingFunction<? super V, U> function, Executor executor) Returns a newClosingFuturepipeline step derived from this one by applying a function that returns aClosingFutureto its value.Methods in com.google.common.util.concurrent with parameters of type ClosingFutureModifier and TypeMethodDescriptionfinal <D> DClosingFuture.Peeker.getDone(ClosingFuture<D> closingFuture) Returns the value ofclosingFuture.private static <C,V extends C>
voidClosingFuture.provideValueAndCloser(ClosingFuture.ValueAndCloserConsumer<C> consumer, ClosingFuture<V> closingFuture) static ClosingFuture.CombinerClosingFuture.whenAllComplete(ClosingFuture<?> future1, ClosingFuture<?>... moreFutures) Starts specifying how to combineClosingFutures into a single pipeline.static ClosingFuture.CombinerClosingFuture.whenAllSucceed(ClosingFuture<?> future1, ClosingFuture<?> future2, ClosingFuture<?> future3, ClosingFuture<?> future4, ClosingFuture<?> future5, ClosingFuture<?> future6, ClosingFuture<?>... moreFutures) Starts specifying how to combineClosingFutures into a single pipeline, assuming they all succeed.static <V1,V2> ClosingFuture.Combiner2<V1, V2> ClosingFuture.whenAllSucceed(ClosingFuture<V1> future1, ClosingFuture<V2> future2) Starts specifying how to combine twoClosingFutures into a single pipeline, assuming they all succeed.static <V1,V2, V3> ClosingFuture.Combiner3<V1, V2, V3> ClosingFuture.whenAllSucceed(ClosingFuture<V1> future1, ClosingFuture<V2> future2, ClosingFuture<V3> future3) Starts specifying how to combine threeClosingFutures into a single pipeline, assuming they all succeed.static <V1,V2, V3, V4>
ClosingFuture.Combiner4<V1,V2, V3, V4> ClosingFuture.whenAllSucceed(ClosingFuture<V1> future1, ClosingFuture<V2> future2, ClosingFuture<V3> future3, ClosingFuture<V4> future4) Starts specifying how to combine fourClosingFutures into a single pipeline, assuming they all succeed.static <V1,V2, V3, V4, V5>
ClosingFuture.Combiner5<V1,V2, V3, V4, V5> ClosingFuture.whenAllSucceed(ClosingFuture<V1> future1, ClosingFuture<V2> future2, ClosingFuture<V3> future3, ClosingFuture<V4> future4, ClosingFuture<V5> future5) Starts specifying how to combine fiveClosingFutures into a single pipeline, assuming they all succeed.Method parameters in com.google.common.util.concurrent with type arguments of type ClosingFutureModifier and TypeMethodDescriptionstatic ClosingFuture.CombinerClosingFuture.whenAllComplete(Iterable<? extends ClosingFuture<?>> futures) Starts specifying how to combineClosingFutures into a single pipeline.static ClosingFuture.CombinerClosingFuture.whenAllSucceed(Iterable<? extends ClosingFuture<?>> futures) Starts specifying how to combineClosingFutures into a single pipeline, assuming they all succeed.Constructors in com.google.common.util.concurrent with parameters of type ClosingFutureModifierConstructorDescriptionprivateCombiner2(ClosingFuture<V1> future1, ClosingFuture<V2> future2) privateCombiner3(ClosingFuture<V1> future1, ClosingFuture<V2> future2, ClosingFuture<V3> future3) privateCombiner4(ClosingFuture<V1> future1, ClosingFuture<V2> future2, ClosingFuture<V3> future3, ClosingFuture<V4> future4) privateCombiner5(ClosingFuture<V1> future1, ClosingFuture<V2> future2, ClosingFuture<V3> future3, ClosingFuture<V4> future4, ClosingFuture<V5> future5) (package private)ValueAndCloser(ClosingFuture<? extends V> closingFuture) Constructor parameters in com.google.common.util.concurrent with type arguments of type ClosingFutureModifierConstructorDescriptionprivateCombiner(boolean allMustSucceed, Iterable<? extends ClosingFuture<?>> inputs) privatePeeker(ImmutableList<ClosingFuture<?>> futures)
Futures of closeable types is dangerous in general because the underlying value may never be closed if theFutureis canceled after its operation begins.