Package | Description |
---|---|
com.google.common.util.concurrent |
Concurrency utilities.
|
Modifier and Type | Method and Description |
---|---|
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 . |
Modifier and Type | Method and Description |
---|---|
(package private) <V,U> FluentFuture<U> |
ClosingFuture.CloseableList.applyAsyncClosingFunction(ClosingFuture.AsyncClosingFunction<V,U> transformation,
V input) |
<X extends java.lang.Throwable> |
ClosingFuture.catchingAsync(java.lang.Class<X> exceptionType,
ClosingFuture.AsyncClosingFunction<? super X,? extends V> fallback,
java.util.concurrent.Executor executor)
Returns a new
ClosingFuture pipeline step derived from this one by applying a function
that returns a ClosingFuture to its exception if it is an instance of a given exception
type. |
private <X extends java.lang.Throwable,W extends V> |
ClosingFuture.catchingAsyncMoreGeneric(java.lang.Class<X> exceptionType,
ClosingFuture.AsyncClosingFunction<? super X,W> fallback,
java.util.concurrent.Executor executor) |
<U> ClosingFuture<U> |
ClosingFuture.transformAsync(ClosingFuture.AsyncClosingFunction<? super V,U> function,
java.util.concurrent.Executor executor)
Returns a new
ClosingFuture pipeline step derived from this one by applying a function
that returns a ClosingFuture to its value. |