(package private) void |
CombinedFuture.CombinedFutureInterruptibleTask.afterRanInterruptiblySuccess(T result) |
|
(package private) abstract void |
InterruptibleTask.afterRanInterruptiblySuccess(T result) |
Any interruption that happens as a result of calling interruptTask will arrive before this
method is called.
|
(package private) void |
TrustedListenableFutureTask.TrustedFutureInterruptibleTask.afterRanInterruptiblySuccess(V result) |
|
ListenableFuture<O> |
AsyncFunction.apply(I input) |
Returns an output Future to use in place of the given input .
|
ClosingFuture<U> |
ClosingFuture.AsyncClosingFunction.apply(ClosingFuture.DeferredCloser closer,
T input) |
Applies this function to an input, or throws an exception if unable to do so.
|
U |
ClosingFuture.ClosingFunction.apply(ClosingFuture.DeferredCloser closer,
T input) |
Applies this function to an input, or throws an exception if unable to do so.
|
ClosingFuture<U> |
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<U> |
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.
|
U |
ClosingFuture.Combiner2.ClosingFunction2.apply(ClosingFuture.DeferredCloser closer,
V1 value1,
V2 value2) |
Applies this function to two inputs, or throws an exception if unable to do so.
|
U |
ClosingFuture.Combiner2.ClosingFunction2.apply(ClosingFuture.DeferredCloser closer,
V1 value1,
V2 value2) |
Applies this function to two inputs, or throws an exception if unable to do so.
|
ClosingFuture<U> |
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<U> |
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<U> |
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.
|
U |
ClosingFuture.Combiner3.ClosingFunction3.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.
|
U |
ClosingFuture.Combiner3.ClosingFunction3.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.
|
U |
ClosingFuture.Combiner3.ClosingFunction3.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<U> |
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<U> |
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<U> |
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<U> |
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.
|
U |
ClosingFuture.Combiner4.ClosingFunction4.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.
|
U |
ClosingFuture.Combiner4.ClosingFunction4.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.
|
U |
ClosingFuture.Combiner4.ClosingFunction4.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.
|
U |
ClosingFuture.Combiner4.ClosingFunction4.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<U> |
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<U> |
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<U> |
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<U> |
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<U> |
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.
|
U |
ClosingFuture.Combiner5.ClosingFunction5.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.
|
U |
ClosingFuture.Combiner5.ClosingFunction5.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.
|
U |
ClosingFuture.Combiner5.ClosingFunction5.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.
|
U |
ClosingFuture.Combiner5.ClosingFunction5.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.
|
U |
ClosingFuture.Combiner5.ClosingFunction5.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.
|
(package private) <V,U> FluentFuture<U> |
ClosingFuture.CloseableList.applyAsyncClosingFunction(ClosingFuture.AsyncClosingFunction<V,U> transformation,
V input) |
|
(package private) <V,U> ListenableFuture<U> |
ClosingFuture.CloseableList.applyClosingFunction(ClosingFuture.ClosingFunction<? super V,U> transformation,
V input) |
|
(package private) abstract void |
AggregateFuture.collectOneValue(int index,
InputT returnValue) |
If allMustSucceed is true, called as each future completes; otherwise, if
collectsValues is true, called for each future when all futures complete.
|
(package private) void |
CollectionFuture.collectOneValue(int index,
V returnValue) |
|
static <V> ListenableFutureTask<V> |
ListenableFutureTask.create(java.lang.Runnable runnable,
V result) |
Creates a ListenableFutureTask that will upon running, execute the given
Runnable , and arrange that get will return the given result on successful completion.
|
(package private) static <V> TrustedListenableFutureTask<V> |
TrustedListenableFutureTask.create(java.lang.Runnable runnable,
V result) |
Creates a ListenableFutureTask that will upon running, execute the given
Runnable , and arrange that get will return the given result on successful completion.
|
(package private) ListenableFuture<? extends O> |
AbstractTransformFuture.AsyncTransformFuture.doTransform(AsyncFunction<? super I,? extends O> function,
I input) |
|
(package private) abstract T |
AbstractTransformFuture.doTransform(F function,
I result) |
Template method for subtypes to actually run the transform.
|
(package private) O |
AbstractTransformFuture.TransformFuture.doTransform(Function<? super I,? extends O> function,
I input) |
|
<C extends java.lang.Object & java.lang.AutoCloseable> C |
ClosingFuture.DeferredCloser.eventuallyClose(C closeable,
java.util.concurrent.Executor closingExecutor) |
Captures an object to be closed when a ClosingFuture pipeline is done.
|
static <V> ListenableFuture<V> |
Futures.immediateFuture(V value) |
Creates a ListenableFuture which has its value set immediately upon construction.
|
static <V> java.util.concurrent.atomic.AtomicReference<V> |
Atomics.newReference(V initialValue) |
Creates an AtomicReference instance with the given initial value.
|
protected <T> java.util.concurrent.RunnableFuture<T> |
AbstractListeningExecutorService.newTaskFor(java.lang.Runnable runnable,
T value) |
|
void |
FutureCallback.onSuccess(V result) |
Invoked with the result of the Future computation when it is successful.
|
static <T> java.util.concurrent.Callable<T> |
Callables.returning(T value) |
Creates a Callable which immediately returns a preset value each time it is called.
|
protected boolean |
AbstractFuture.set(V value) |
Sets the result of this Future unless this Future has already been cancelled or
set (including set asynchronously).
|
boolean |
SettableFuture.set(V value) |
|
(package private) void |
AbstractCatchingFuture.CatchingFuture.setResult(V result) |
|
(package private) abstract void |
AbstractCatchingFuture.setResult(T result) |
Template method for subtypes to actually set the result.
|
(package private) abstract void |
AbstractTransformFuture.setResult(T result) |
Template method for subtypes to actually set the result.
|
(package private) void |
AbstractTransformFuture.TransformFuture.setResult(O result) |
|
(package private) void |
CombinedFuture.CallableInterruptibleTask.setValue(V value) |
|
(package private) abstract void |
CombinedFuture.CombinedFutureInterruptibleTask.setValue(T value) |
|
<T> ListenableFuture<T> |
AbstractListeningExecutorService.submit(java.lang.Runnable task,
T result) |
|
<T> java.util.concurrent.Future<T> |
ForwardingExecutorService.submit(java.lang.Runnable task,
T result) |
|
<T> ListenableFuture<T> |
ForwardingListeningExecutorService.submit(java.lang.Runnable task,
T result) |
|
<T> ListenableFuture<T> |
ListeningExecutorService.submit(java.lang.Runnable task,
T result) |
|
<T> java.util.concurrent.Future<T> |
WrappingExecutorService.submit(java.lang.Runnable task,
T result) |
|