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

Modifier	Constructor	Description
protected	Backlog(ThrowingFunction<List<T>,CompletableFuture<?>> consumer)
protected	Backlog(ThrowingFunction<List<T>,CompletableFuture<?>> consumer, int maxBatchSize)
protected	Backlog(ThrowingFunction<List<T>,CompletableFuture<?>> consumer, int maxBatchSize, ErrorHandler<List<T>> errorHandler)

Method Summary

Modifier and Type	Method	Description
CompletableFuture<Void>	add(Collection<? extends T> values)
final CompletableFuture<Void>	add(T... values)
protected void	completeResults(long untilPosition, Throwable e)
static <T> Backlog<T>	forAsyncConsumer(ThrowingFunction<List<T>,CompletableFuture<?>> consumer)
static <T> Backlog<T>	forAsyncConsumer(ThrowingFunction<List<T>,CompletableFuture<?>> consumer, int maxBatchSize)
static <T> Backlog<T>	forAsyncConsumer(ThrowingFunction<List<T>,CompletableFuture<?>> consumer, int maxBatchSize, ErrorHandler<List<T>> errorHandler)
static <T> Backlog<T>	forConsumer(ThrowingConsumer<List<T>> consumer)
static <T> Backlog<T>	forConsumer(ThrowingConsumer<List<T>> consumer, int maxBatchSize)
static <T> Backlog<T>	forConsumer(ThrowingConsumer<List<T>> consumer, int maxBatchSize, ErrorHandler<List<T>> errorHandler)
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

protected Backlog(ThrowingFunction<List<T>,CompletableFuture<?>> consumer)

Backlog

protected Backlog(ThrowingFunction<List<T>,CompletableFuture<?>> consumer,
 int maxBatchSize)

Backlog

protected Backlog(ThrowingFunction<List<T>,CompletableFuture<?>> consumer,
 int maxBatchSize,
 ErrorHandler<List<T>> errorHandler)

Method Details

forConsumer

public static <T> Backlog<T> forConsumer(ThrowingConsumer<List<T>> consumer)

forConsumer

public static <T> Backlog<T> forConsumer(ThrowingConsumer<List<T>> consumer,
 int maxBatchSize)

forConsumer

public static <T> Backlog<T> forConsumer(ThrowingConsumer<List<T>> consumer,
 int maxBatchSize,
 ErrorHandler<List<T>> errorHandler)

forAsyncConsumer

public static <T> Backlog<T> forAsyncConsumer(ThrowingFunction<List<T>,CompletableFuture<?>> consumer)

forAsyncConsumer

public static <T> Backlog<T> forAsyncConsumer(ThrowingFunction<List<T>,CompletableFuture<?>> consumer,
 int maxBatchSize)

forAsyncConsumer

public static <T> Backlog<T> forAsyncConsumer(ThrowingFunction<List<T>,CompletableFuture<?>> consumer,
 int maxBatchSize,
 ErrorHandler<List<T>> errorHandler)

add

@SafeVarargs
public final CompletableFuture<Void> add(T... values)

add

public CompletableFuture<Void> add(Collection<? extends T> values)

completeResults

protected void completeResults(long untilPosition,
 Throwable e)

registerMonitor

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

Specified by:

registerMonitor in interface Monitored<T>

shutDown

public void shutDown()