Package | Description |
---|---|
com.google.common.util.concurrent |
Concurrency utilities.
|
Modifier and Type | Class and Description |
---|---|
(package private) class |
AbstractCatchingFuture<V,X extends java.lang.Throwable,F,T>
Implementations of
Futures.catching* . |
private static class |
AbstractCatchingFuture.AsyncCatchingFuture<V,X extends java.lang.Throwable>
An
AbstractCatchingFuture that delegates to an AsyncFunction and AbstractFuture.setFuture(ListenableFuture) . |
private static class |
AbstractCatchingFuture.CatchingFuture<V,X extends java.lang.Throwable>
|
(package private) class |
AbstractTransformFuture<I,O,F,T>
Implementations of
Futures.transform* . |
private static class |
AbstractTransformFuture.AsyncTransformFuture<I,O>
An
AbstractTransformFuture that delegates to an AsyncFunction and AbstractFuture.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 of
Futures#withTimeout . |
(package private) class |
TrustedListenableFutureTask<V>
A
RunnableFuture that also implements the ListenableFuture interface. |
Modifier and Type | Field and Description |
---|---|
private FluentFuture<V> |
ClosingFuture.future |
Modifier and Type | Field and Description |
---|---|
private static Function<ClosingFuture<?>,FluentFuture<?>> |
ClosingFuture.Combiner.INNER_FUTURE |
Modifier and Type | Method and 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.catching(java.lang.Class<X> exceptionType,
Function<? super X,? extends V> fallback,
java.util.concurrent.Executor executor)
Returns a
Future whose result is taken from this Future or, if this Future fails with the given exceptionType , from the result provided by the fallback . |
<X extends java.lang.Throwable> |
FluentFuture.catchingAsync(java.lang.Class<X> exceptionType,
AsyncFunction<? super X,? extends V> fallback,
java.util.concurrent.Executor executor)
Returns a
Future whose result is taken from this Future or, if this Future fails with the given exceptionType , from the result provided by the fallback . |
FluentFuture<V> |
ClosingFuture.finishToFuture()
Marks this step as the last step in the
ClosingFuture pipeline. |
static <V> FluentFuture<V> |
FluentFuture.from(FluentFuture<V> future)
Deprecated.
no need to use this
|
static <V> FluentFuture<V> |
FluentFuture.from(ListenableFuture<V> future)
Converts the given
ListenableFuture to an equivalent FluentFuture . |
<T> FluentFuture<T> |
FluentFuture.transform(Function<? super V,T> function,
java.util.concurrent.Executor executor)
Returns a new
Future whose result is derived from the result of this Future . |
<T> FluentFuture<T> |
FluentFuture.transformAsync(AsyncFunction<? super V,T> function,
java.util.concurrent.Executor executor)
Returns a new
Future whose result is asynchronously derived from the result of this
Future . |
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 a
TimeoutException wrapped in an ExecutionException ) if the specified timeout expires. |
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 a
TimeoutException wrapped in an ExecutionException ) if the specified timeout expires. |
Modifier and Type | Method and Description |
---|---|
private ImmutableList<FluentFuture<?>> |
ClosingFuture.Combiner.inputFutures() |
Modifier and Type | Method and 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
|