Uses of Class
io.fluxcapacitor.common.Backlog

Packages that use Backlog

Package	Description
io.fluxcapacitor.common

Uses of Backlog in io.fluxcapacitor.common

Methods in io.fluxcapacitor.common that return Backlog

Modifier and Type	Method	Description
static <T> Backlog<T>	Backlog.forAsyncConsumer(ThrowingFunction<List<T>,CompletableFuture<?>> consumer)
static <T> Backlog<T>	Backlog.forAsyncConsumer(ThrowingFunction<List<T>,CompletableFuture<?>> consumer, int maxBatchSize)
static <T> Backlog<T>	Backlog.forAsyncConsumer(ThrowingFunction<List<T>,CompletableFuture<?>> consumer, int maxBatchSize, ErrorHandler<List<T>> errorHandler)
static <T> Backlog<T>	Backlog.forConsumer(ThrowingConsumer<List<T>> consumer)
static <T> Backlog<T>	Backlog.forConsumer(ThrowingConsumer<List<T>> consumer, int maxBatchSize)
static <T> Backlog<T>	Backlog.forConsumer(ThrowingConsumer<List<T>> consumer, int maxBatchSize, ErrorHandler<List<T>> errorHandler)