Class PromiseAggregator<V,F extends Future<V>>

java.lang.Object
io.netty.util.concurrent.PromiseAggregator<V,F>
Type Parameters:
V - the type of value returned by the Future
F - the type of Future
All Implemented Interfaces:
GenericFutureListener<F>, EventListener
Direct Known Subclasses:
ChannelPromiseAggregator

@Deprecated public class PromiseAggregator<V,F extends Future<V>> extends Object implements GenericFutureListener<F>
Deprecated.
Use PromiseCombiner(EventExecutor). GenericFutureListener implementation which consolidates multiple Futures into one, by listening to individual Futures and producing an aggregated result (success/failure) when all Futures have completed.
  • Field Details

    • aggregatePromise

      private final Promise<?> aggregatePromise
      Deprecated.
    • failPending

      private final boolean failPending
      Deprecated.
    • pendingPromises

      private Set<Promise<V>> pendingPromises
      Deprecated.
  • Constructor Details

    • PromiseAggregator

      public PromiseAggregator(Promise<Void> aggregatePromise, boolean failPending)
      Deprecated.
      Creates a new instance.
      Parameters:
      aggregatePromise - the Promise to notify
      failPending - true to fail pending promises, false to leave them unaffected
    • PromiseAggregator

      public PromiseAggregator(Promise<Void> aggregatePromise)
      Deprecated.
      See PromiseAggregator(Promise, boolean). Defaults failPending to true.
  • Method Details