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

    • Field Detail

      • aggregatePromise

        private final Promise<?> aggregatePromise
        Deprecated.
      • failPending

        private final boolean failPending
        Deprecated.
      • pendingPromises

        private java.util.Set<Promise<V>> pendingPromises
        Deprecated.
    • Constructor Detail

      • PromiseAggregator

        public PromiseAggregator​(Promise<java.lang.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
    • Method Detail

      • operationComplete

        public void operationComplete​(F future)
                               throws java.lang.Exception
        Deprecated.
        Description copied from interface: GenericFutureListener
        Invoked when the operation associated with the Future has been completed.
        Specified by:
        operationComplete in interface GenericFutureListener<V>
        Parameters:
        future - the source Future which called this callback
        Throws:
        java.lang.Exception