Uses of Class
io.fluxcapacitor.common.Backlog
Packages that use Backlog
-
Uses of Backlog in io.fluxcapacitor.common
Methods in io.fluxcapacitor.common that return BacklogModifier and TypeMethodDescriptionstatic <T> Backlog
<T> Backlog.forAsyncConsumer
(ThrowingFunction<List<T>, CompletableFuture<?>> consumer) Creates a backlog for an asynchronous consumer with default max batch size and default logging error handler.static <T> Backlog
<T> Backlog.forAsyncConsumer
(ThrowingFunction<List<T>, CompletableFuture<?>> consumer, int maxBatchSize) Creates a backlog for an asynchronous consumer with custom max batch size and default logging 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) Creates a new backlog for a synchronous consumer and default batch size and default logging error handler.static <T> Backlog
<T> Backlog.forConsumer
(ThrowingConsumer<List<T>> consumer, int maxBatchSize) Creates a backlog with custom max batch size and default logging 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.