EMPTY_CONSUMER
Constructor and Description |
---|
BufferedListConsumer(int size,
Consumer<? super java.util.List<T>> consumer,
int interval) |
Modifier and Type | Method and Description |
---|---|
void |
consume(java.util.List<T> list) |
void |
consumeOne(T t) |
void |
flush() |
int |
getCnt() |
protected void |
invokeConsumer(java.lang.Runnable consumerRunnable) |
public void consumeOne(T t)
public void consume(java.util.List<T> list)
consume
in interface Consumer<java.util.List<T>>
list
- consequently takes value of each element of the set this processor is passed to for processing.
t is supposed to be a not-null value. If you need to pass null
s to the consumer use NullableConsumer
insteadprotected void invokeConsumer(java.lang.Runnable consumerRunnable)
public void flush()
public int getCnt()