Uses of Class
io.fluxzero.common.Backlog
Packages that use Backlog
-
Uses of Backlog in io.fluxzero.common
Methods in io.fluxzero.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.