Package | Description |
---|---|
com.google.common.util.concurrent |
Concurrency utilities.
|
Modifier and Type | Field and Description |
---|---|
private static AsyncFunction<ListenableFuture<java.lang.Object>,java.lang.Object> |
Futures.DEREFERENCER
|
Modifier and Type | Method and Description |
---|---|
static <V,X extends java.lang.Throwable> |
Futures.catchingAsync(ListenableFuture<? extends V> input,
java.lang.Class<X> exceptionType,
AsyncFunction<? super X,? extends V> fallback)
Returns a
Future whose result is taken from the given primary input or, if the
primary input fails with the given exceptionType , from the result provided by the
fallback . |
static <V,X extends java.lang.Throwable> |
Futures.catchingAsync(ListenableFuture<? extends V> input,
java.lang.Class<X> exceptionType,
AsyncFunction<? super X,? extends V> fallback,
java.util.concurrent.Executor executor)
Returns a
Future whose result is taken from the given primary input or, if the
primary input fails with the given exceptionType , from the result provided by the
fallback . |
(package private) static <X extends java.lang.Throwable,V> |
AbstractCatchingFuture.create(ListenableFuture<? extends V> input,
java.lang.Class<X> exceptionType,
AsyncFunction<? super X,? extends V> fallback) |
(package private) static <X extends java.lang.Throwable,V> |
AbstractCatchingFuture.create(ListenableFuture<? extends V> input,
java.lang.Class<X> exceptionType,
AsyncFunction<? super X,? extends V> fallback,
java.util.concurrent.Executor executor) |
(package private) static <I,O> ListenableFuture<O> |
AbstractTransformFuture.create(ListenableFuture<I> input,
AsyncFunction<? super I,? extends O> function) |
(package private) static <I,O> ListenableFuture<O> |
AbstractTransformFuture.create(ListenableFuture<I> input,
AsyncFunction<? super I,? extends O> function,
java.util.concurrent.Executor executor) |
(package private) ListenableFuture<? extends V> |
AbstractCatchingFuture.AsyncCatchingFuture.doFallback(AsyncFunction<? super X,? extends V> fallback,
X cause) |
(package private) ListenableFuture<? extends O> |
AbstractTransformFuture.AsyncTransformFuture.doTransform(AsyncFunction<? super I,? extends O> function,
I input) |
static <I,O> ListenableFuture<O> |
Futures.transformAsync(ListenableFuture<I> input,
AsyncFunction<? super I,? extends O> function)
Returns a new
Future whose result is asynchronously derived from the result of the
given Future . |
static <I,O> ListenableFuture<O> |
Futures.transformAsync(ListenableFuture<I> input,
AsyncFunction<? super I,? extends O> function,
java.util.concurrent.Executor executor)
Returns a new
Future whose result is asynchronously derived from the result of the
given Future . |
Constructor and Description |
---|
AsyncCatchingFuture(ListenableFuture<? extends V> input,
java.lang.Class<X> exceptionType,
AsyncFunction<? super X,? extends V> fallback) |
AsyncTransformFuture(ListenableFuture<? extends I> inputFuture,
AsyncFunction<? super I,? extends O> function) |