Package com.google.common.util.concurrent

Class AbstractTransformFuture<I,O,F,T>

java.lang.Object

com.google.common.util.concurrent.internal.InternalFutureFailureAccess

com.google.common.util.concurrent.AbstractFuture<V>

com.google.common.util.concurrent.GwtFluentFutureCatchingSpecialization<V>

com.google.common.util.concurrent.FluentFuture<V>

com.google.common.util.concurrent.FluentFuture.TrustedFuture<O>

com.google.common.util.concurrent.AbstractTransformFuture<I,O,F,T>

All Implemented Interfaces:

AbstractFuture.Trusted<O>, ListenableFuture<O>, java.lang.Runnable, java.util.concurrent.Future<O>

Direct Known Subclasses:

AbstractTransformFuture.AsyncTransformFuture, AbstractTransformFuture.TransformFuture

@GwtCompatible
abstract class AbstractTransformFuture<I,O,F,T>
extends FluentFuture.TrustedFuture<O>
implements java.lang.Runnable

Implementations of Futures.transform*.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
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>	An AbstractTransformFuture that delegates to a Function and AbstractFuture.set(Object).

Nested classes/interfaces inherited from class com.google.common.util.concurrent.FluentFuture

FluentFuture.TrustedFuture<V>

Nested classes/interfaces inherited from class com.google.common.util.concurrent.AbstractFuture

AbstractFuture.Trusted<V>

Field Summary

Fields

Modifier and Type	Field	Description
(package private) F	function
(package private) ListenableFuture<? extends I>	inputFuture

Constructor Summary

Constructors

Constructor	Description
AbstractTransformFuture(ListenableFuture<? extends I> inputFuture, F function)

Method Summary

Modifier and Type	Method	Description
protected void	afterDone()	Callback method that is called exactly once after the future is completed.
(package private) static <I,O> ListenableFuture<O>	create(ListenableFuture<I> input, Function<? super I,? extends O> function, java.util.concurrent.Executor executor)
(package private) static <I,O> ListenableFuture<O>	create(ListenableFuture<I> input, AsyncFunction<? super I,? extends O> function, java.util.concurrent.Executor executor)
(package private) abstract T	doTransform(F function, I result)	Template method for subtypes to actually run the transform.
protected java.lang.String	pendingToString()	Provide a human-readable explanation of why this future has not yet completed.
void	run()
(package private) abstract void	setResult(T result)	Template method for subtypes to actually set the result.

Methods inherited from class com.google.common.util.concurrent.FluentFuture.TrustedFuture

addListener, cancel, get, get, isCancelled, isDone

Methods inherited from class com.google.common.util.concurrent.FluentFuture

addCallback, catching, catchingAsync, from, from, transform, transformAsync, withTimeout, withTimeout

Methods inherited from class com.google.common.util.concurrent.AbstractFuture

interruptTask, maybePropagateCancellationTo, set, setException, setFuture, toString, tryInternalFastPathGetFailure, wasInterrupted

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

inputFuture

ListenableFuture<? extends I> inputFuture

function

F function

Constructor Detail

AbstractTransformFuture

AbstractTransformFuture(ListenableFuture<? extends I> inputFuture,
                        F function)

Method Detail

create

static <I,O> ListenableFuture<O> create(ListenableFuture<I> input,
                                              AsyncFunction<? super I,? extends O> function,
                                              java.util.concurrent.Executor executor)

create

static <I,O> ListenableFuture<O> create(ListenableFuture<I> input,
                                              Function<? super I,? extends O> function,
                                              java.util.concurrent.Executor executor)

run

public final void run()

Specified by:

run in interface java.lang.Runnable

doTransform

abstract T doTransform(F function,
                       I result)
                throws java.lang.Exception

Template method for subtypes to actually run the transform.

Throws:

java.lang.Exception

setResult

abstract void setResult(T result)

Template method for subtypes to actually set the result.

afterDone

protected final void afterDone()

Description copied from class: AbstractFuture

Callback method that is called exactly once after the future is completed.

If AbstractFuture.interruptTask() is also run during completion, AbstractFuture.afterDone() runs after it.

The default implementation of this method in AbstractFuture does nothing. This is intended for very lightweight cleanup work, for example, timing statistics or clearing fields. If your task does anything heavier consider, just using a listener with an executor.

Overrides:

afterDone in class AbstractFuture<O>

pendingToString

protected java.lang.String pendingToString()

Description copied from class: AbstractFuture

Provide a human-readable explanation of why this future has not yet completed.

Overrides:

pendingToString in class AbstractFuture<O>

Returns:

null if an explanation cannot be provided because the future is done.