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

    • 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