Package jadex.future

Class UnlimitedIntermediateDelegationResultListener<E>

java.lang.Object
jadex.future.UnlimitedIntermediateDelegationResultListener<E>
All Implemented Interfaces:
IIntermediateResultListener<E>, IResultListener<Collection<E>>
public class UnlimitedIntermediateDelegationResultListener<E> extends Object implements IIntermediateResultListener<E>
Listener that forwards results but not finished events.

  • Field Details

  • Constructor Details

    • UnlimitedIntermediateDelegationResultListener

      public UnlimitedIntermediateDelegationResultListener(IntermediateFuture<E> delegate)
      Create a new UnlimitedIntermediateDelegationResultListener.

  • Method Details

    • intermediateResultAvailable

      public void intermediateResultAvailable(E result)
      Called when an intermediate result is available.
      Specified by:
      intermediateResultAvailable in interface IIntermediateResultListener<E>
      Parameters:
      result - The result.

    • finished

      public void finished()
      Declare that the future is finished. This method is only called for intermediate futures, i.e. when this method is called it is guaranteed that the intermediateResultAvailable method was called for all intermediate results before.
      Specified by:
      finished in interface IIntermediateResultListener<E>

    • resultAvailable

      public void resultAvailable(Collection<E> results)
      Called when the result is available. This method is only called for non-intermediate futures, i.e. when this method is called it is guaranteed that the intermediateResultAvailable method has not been called.
      Specified by:
      resultAvailable in interface IResultListener<E>
      Parameters:
      results - The final result.

    • exceptionOccurred

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

    • maxResultCountAvailable

      public void maxResultCountAvailable(int max)
      Declare that the future result count is available. This method is only called for intermediate futures, i.e. when this method is called it is guaranteed that the intermediateResultAvailable method will be called as often as the result count indicates.
      Specified by:
      maxResultCountAvailable in interface IIntermediateResultListener<E>