Class BufferedListConsumer<T>

    • Constructor Detail

      • BufferedListConsumer

        public BufferedListConsumer​(int size,
                                    Consumer<List<T>> consumer,
                                    int interval)
    • Method Detail

      • consumeOne

        public void consumeOne​(T t)
      • consume

        public void consume​(List<T> list)
        Specified by:
        consume in interface Consumer<T>
        Parameters:
        list - consequently takes value of each element of the set this processor is passed to for processing.
      • flush

        public void flush()