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

    • Field Detail

      • promises

        private final Promise<? super V>[] promises
      • logNotifyFailure

        private final boolean logNotifyFailure
    • Constructor Detail

      • PromiseNotifier

        @SafeVarargs
        public PromiseNotifier​(Promise<? super V>... promises)
        Create a new instance.
        Parameters:
        promises - the Promises to notify once this GenericFutureListener is notified.
      • PromiseNotifier

        @SafeVarargs
        public PromiseNotifier​(boolean logNotifyFailure,
                               Promise<? super V>... promises)
        Create a new instance.
        Parameters:
        logNotifyFailure - true if logging should be done in case notification fails.
        promises - the Promises to notify once this GenericFutureListener is notified.
    • Method Detail

      • operationComplete

        public void operationComplete​(F future)
                               throws java.lang.Exception
        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