Uses of Interface
io.fluxzero.common.ErrorHandler

Packages that use ErrorHandler

Package	Description
io.fluxzero.common

Uses of ErrorHandler in io.fluxzero.common

Methods in io.fluxzero.common with parameters of type ErrorHandler

Modifier and Type	Method	Description
static <T> Backlog<T>	Backlog.forAsyncConsumer(ThrowingFunction<List<T>, CompletableFuture<?>> consumer, int maxBatchSize, int maxInFlightBatches, ErrorHandler<List<T>> errorHandler)	Creates a bounded asynchronous backlog with a custom error handler.
static <T> Backlog<T>	Backlog.forAsyncConsumer(ThrowingFunction<List<T>, CompletableFuture<?>> consumer, int maxBatchSize, ErrorHandler<List<T>> errorHandler)	Creates a backlog for an asynchronous consumer with custom max batch size and error handler.
static <T> Backlog<T>	Backlog.forConsumer(ThrowingConsumer<List<T>> consumer, int maxBatchSize, ErrorHandler<List<T>> errorHandler)	Creates a backlog with custom max batch size and error handler.
static <T> Backlog<T>	Backlog.forOrderedAsyncConsumer(ThrowingFunction<List<T>, CompletableFuture<?>> consumer, int maxBatchSize, ErrorHandler<List<T>> errorHandler)	Deprecated, for removal: This API element is subject to removal in a future version. Use Backlog.forAsyncConsumer(ThrowingFunction, int, int, ErrorHandler) with one in-flight batch.

Constructors in io.fluxzero.common with parameters of type ErrorHandler

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