Class FlattenMultiplexCollector

    • Field Summary

      Fields 
      Modifier and Type Field Description
      protected java.util.List<java.lang.Object> callresults
      The list of results (if ret is not intermediate future).
      protected java.util.List<Future<java.lang.Void>> calls
      The list of calls.
      protected boolean flatten
      Flag if flatten.
      protected Future<java.lang.Object> fut
      The future.
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      protected void addResult​(java.lang.Object result)
      Add a result.
      void exceptionOccurred​(java.lang.Exception exception)
      Called when an exception occurred.
      void finished()
      Declare that the future is finished.
      void init​(Future<java.lang.Object> fut, java.lang.reflect.Method method, java.lang.Object[] args, java.lang.reflect.Method muxmethod)
      Init to share code.
      void intermediateResultAvailable​(java.lang.Object result)
      Called when an intermediate result is available.
      void resultAvailable​(java.util.Collection<java.lang.Object> result)
      Called when the result is available.
      protected void setException​(java.lang.Exception exception)
      Set an exception.
      protected void setFinished()
      Set finished.
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Field Detail

      • fut

        protected Future<java.lang.Object> fut
        The future.
      • flatten

        protected boolean flatten
        Flag if flatten.
      • calls

        protected java.util.List<Future<java.lang.Void>> calls
        The list of calls.
      • callresults

        protected java.util.List<java.lang.Object> callresults
        The list of results (if ret is not intermediate future).
    • Constructor Detail

      • FlattenMultiplexCollector

        public FlattenMultiplexCollector()
    • Method Detail

      • init

        public void init​(Future<java.lang.Object> fut,
                         java.lang.reflect.Method method,
                         java.lang.Object[] args,
                         java.lang.reflect.Method muxmethod)
        Init to share code.
        Specified by:
        init in interface IMultiplexCollector
      • resultAvailable

        public void resultAvailable​(java.util.Collection<java.lang.Object> result)
        Description copied from interface: IFunctionalResultListener
        Called when the result is available.
        Specified by:
        resultAvailable in interface IFunctionalResultListener<java.util.Collection<java.lang.Object>>
        Parameters:
        result - The result.
      • addResult

        protected void addResult​(java.lang.Object result)
        Add a result.
        Parameters:
        result - The result.
      • setFinished

        protected void setFinished()
        Set finished.
      • setException

        protected void setException​(java.lang.Exception exception)
        Set an exception.
        Parameters:
        exception - The exception.