Package io.fluxcapacitor.common

Class Backlog<T>

java.lang.Object

io.fluxcapacitor.common.Backlog<T>

All Implemented Interfaces:

Monitored<List<T>>

public class Backlog<T>
extends Object
implements Monitored<List<T>>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	Backlog.BatchConsumer<T>

Constructor Summary

Constructors

Constructor	Description
Backlog(Backlog.BatchConsumer<T> consumer)
Backlog(Backlog.BatchConsumer<T> consumer, int maxBatchSize)
Backlog(Backlog.BatchConsumer<T> consumer, int maxBatchSize, int threads, ErrorHandler<List<T>> errorHandler)

Method Summary

Modifier and Type	Method	Description
Awaitable	add(Collection<? extends T> values)
Awaitable	add(T... values)
Registration	registerMonitor(Consumer<List<T>> monitor)
void	shutDown()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

Backlog

public Backlog(Backlog.BatchConsumer<T> consumer)

Backlog

public Backlog(Backlog.BatchConsumer<T> consumer,
int maxBatchSize)

Backlog

public Backlog(Backlog.BatchConsumer<T> consumer,
int maxBatchSize,
int threads,
ErrorHandler<List<T>> errorHandler)

Method Details

add

@SafeVarargs
public final Awaitable add(T... values)

add

public Awaitable add(Collection<? extends T> values)

registerMonitor

public Registration registerMonitor(Consumer<List<T>> monitor)

Specified by:

registerMonitor in interface Monitored<T>

shutDown

public void shutDown()