Package one.microstream.util

Interface BufferingCollector<E>

Type Parameters:

E -

All Known Implementing Classes:

BufferingCollector.Default

public interface BufferingCollector<E>

An instance that collects (buffers) elements and gets notified once the collecting process is completed.

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static class	BufferingCollector.Default<E>

Method Summary

Modifier and Type	Method	Description
void	accept(E element)
void	finalizeElements()
default boolean	isEmpty()
static <E> BufferingCollector<E>	New(Consumer<? super E> finalizingLogic)
static <E> BufferingCollector<E>	New(Consumer<? super E> finalizingLogic, Consumer<? super E> collectingListener)
void	resetElements()
long	size()

Method Details

accept

void accept(E element)

resetElements

void resetElements()

finalizeElements

void finalizeElements()

size

long size()

isEmpty

default boolean isEmpty()

New

static <E> BufferingCollector<E> New(Consumer<? super E> finalizingLogic)

New

static <E> BufferingCollector<E> New(Consumer<? super E> finalizingLogic, Consumer<? super E> collectingListener)