Package jadex.future

Class CounterResultListener<E>

java.lang.Object
jadex.future.CounterResultListener<E>
All Implemented Interfaces:
IResultListener<E>, IUndoneResultListener<E>

public class CounterResultListener<E> extends Object implements IResultListener<E>, IUndoneResultListener<E>
Counter result listener for counting a specified number of resultAvailable calls.
  • Field Details

    • num

      protected int num
      The number of sub listeners to wait for.
    • cnt

      protected int cnt
      The number of received callbacks.
    • delegate

      protected IResultListener<Void> delegate
      The delegate result listener.
    • notified

      protected boolean notified
      Flag to indicate that the delegate already has been notified.
    • ignorefailures

      protected boolean ignorefailures
      The ignore failure flag.
    • undone

      protected boolean undone
      The undone flag.
  • Constructor Details

    • CounterResultListener

      public CounterResultListener(int num, IResultListener<Void> delegate)
      Create a new counter listener.
      Parameters:
      num - The number of sub callbacks.
    • CounterResultListener

      public CounterResultListener(int num, boolean ignorefailures, IResultListener<Void> delegate)
      Create a new counter listener.
      Parameters:
      num - The number of sub callbacks.
  • Method Details

    • resultAvailable

      public void resultAvailable(E result)
      Called when the result is available.
      Specified by:
      resultAvailable in interface IResultListener<E>
      Parameters:
      result - The result.
    • exceptionOccurred

      public void exceptionOccurred(Exception exception)
      Called when an exception occurred.
      Specified by:
      exceptionOccurred in interface IResultListener<E>
      Parameters:
      exception - The exception.
    • intermediateResultAvailable

      public void intermediateResultAvailable(E result)
      Method that can be overridden to do sth. on each result available call.
    • intermediateExceptionOccurred

      public boolean intermediateExceptionOccurred(Exception exception)
      Method that can be overridden to do sth. on each exception that occurs.
      Returns:
      True, for retry the task (cnt is not increased);
    • getNumber

      public int getNumber()
      Get the number of results this Listener is waiting for.
      Returns:
      The expected number of results.
    • setNumber

      public void setNumber(int num)
      Set the number.
      Parameters:
      num - The number.
    • getCnt

      public int getCnt()
      Get the current number of received results.
      Returns:
      Number of results.
    • resultAvailableIfUndone

      public void resultAvailableIfUndone(E result)
      Called when the result is available.
      Specified by:
      resultAvailableIfUndone in interface IUndoneResultListener<E>
      Parameters:
      result - The result.
    • exceptionOccurredIfUndone

      public void exceptionOccurredIfUndone(Exception exception)
      Called when an exception occurred.
      Specified by:
      exceptionOccurredIfUndone in interface IUndoneResultListener<E>
      Parameters:
      exception - The exception.
    • isUndone

      public boolean isUndone()
      Get the undone.
      Returns:
      The undone.