Class AggregateFuture<InputT,​OutputT>

    • Constructor Detail

      • AggregateFuture

        AggregateFuture()
    • Method Detail

      • 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<OutputT>
      • addCausalChain

        private static boolean addCausalChain​(java.util.Set<java.lang.Throwable> seen,
                                              java.lang.Throwable t)
        Adds the chain to the seen set, and returns whether all the chain was new to us.