Package | Description |
---|---|
com.google.common.util.concurrent |
Concurrency utilities.
|
Modifier and Type | Method and Description |
---|---|
<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 . |
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 . |
<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 . |
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 . |
static <V,U> ClosingFuture.AsyncClosingFunction<V,U> |
ClosingFuture.withoutCloser(AsyncFunction<V,U> function)
Returns an
ClosingFuture.AsyncClosingFunction that applies an AsyncFunction to an input,
ignoring the DeferredCloser and returning a ClosingFuture derived from the returned
ListenableFuture . |
Copyright © 2010–2021 JBoss by Red Hat. All rights reserved.