Interface Accumulator<T>

Type Parameters:
T - the type
All Superinterfaces:
Consumer<T>
All Known Implementing Classes:
CallbackAccumulator, ListAccumulator, SetAccumulator, SetAccumulatorWrapper, SizeRestrictedAccumulatorWrapper
public interface Accumulator<T> extends Consumer<T>
The interface provides a mechanism for clients to pass around an object that is effectively a 'results object', into which data can be placed as it is discovered.

Historically, clients that load data will return results, once fully loaded, in a Collection. This has the drawback that the discovered data cannot be used until all searching is complete. This interface can now be passed into such a method (as opposed to be returned by it) so that the client can make use of data as it is discovered. This allows for long searching processes to report data as they work.

Using this class implies that data will be added asynchronously. Implementations of this interface should properly synchronize storage so that the data written is visible to the client thread.

  • Method Summary

    Change
    Modifier and Type
    Method
    Description
    default void
    accept(T t)
     
    void
    add(T t)
     
    void
    addAll(Collection<T> collection)
     
    int
    getProgress()
    Returns the number of items that have been added to this accumulator.
    REMOVED
    boolean
    contains(T t)
    Removed
    REMOVED
    Collection<T>
    get()
    Removed
    REMOVED
    int
    size()
    Removed
    REMOVED
    boolean
    isEmpty()
    Removed
    REMOVED
    Stream<T>
    stream()
    Removed

    Methods inherited from interface Consumer

    andThen

  • Method Details

    • add

      void add(T t)

    • addAll

      void addAll(Collection<T> collection)

    • getProgress NEW

      int getProgress()
      Returns the number of items that have been added to this accumulator.
      Returns:
      the number of items that have been added to this accumulator

    • accept

      default void accept(T t)
      Specified by:
      accept in interface Consumer<T>