Uses of Class
io.fluxzero.common.Backlog

Packages that use Backlog

Package	Description
io.fluxzero.common

Uses of Backlog in io.fluxzero.common

Methods in io.fluxzero.common that return Backlog

Modifier and Type	Method	Description
static <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, int maxInFlightBatches)	Creates a backlog for an asynchronous consumer with a bounded number of in-flight batches.
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.forAsyncConsumer(ThrowingFunction<List<T>, CompletableFuture<?>> consumer, int maxBatchSize, ToLongFunction<? super T> itemWeight, long maxBatchWeight, int maxInFlightBatches)	Creates an asynchronous backlog bounded by item count, cumulative item weight and in-flight batches.
static <T> Backlog<T>	Backlog.forAsyncConsumer(ThrowingFunction<List<T>, CompletableFuture<?>> consumer, int maxBatchSize, ToLongFunction<? super T> itemWeight, long maxBatchWeight, int maxInFlightBatches, Duration batchCollectionDelay)	Creates an asynchronous backlog bounded by item count, cumulative item weight and in-flight batches, with a bounded collection delay whenever an idle backlog starts flushing.
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.
static <T> Backlog<T>	Backlog.forOrderedAsyncConsumer(ThrowingFunction<List<T>, CompletableFuture<?>> consumer)	Deprecated, for removal: This API element is subject to removal in a future version. Use Backlog.forAsyncConsumer(ThrowingFunction, int, int) with one in-flight batch.
static <T> Backlog<T>	Backlog.forOrderedAsyncConsumer(ThrowingFunction<List<T>, CompletableFuture<?>> consumer, int maxBatchSize)	Deprecated, for removal: This API element is subject to removal in a future version. Use Backlog.forAsyncConsumer(ThrowingFunction, int, int) with one in-flight batch.
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.
static <T> Backlog<T>	Backlog.forOrderedAsyncConsumer(ThrowingFunction<List<T>, CompletableFuture<?>> consumer, int maxBatchSize, ToLongFunction<? super T> batchWeight, long maxBatchWeight)	Deprecated, for removal: This API element is subject to removal in a future version. Use Backlog.forAsyncConsumer(ThrowingFunction, int, ToLongFunction, long, int) with one in-flight batch.
static <T> Backlog<T>	Backlog.forOrderedAsyncConsumer(ThrowingFunction<List<T>, CompletableFuture<?>> consumer, int maxBatchSize, ToLongFunction<? super T> batchWeight, long maxBatchWeight, Duration batchCollectionDelay)	Deprecated, for removal: This API element is subject to removal in a future version. Use Backlog.forAsyncConsumer(ThrowingFunction, int, ToLongFunction, long, int, Duration) with one in-flight batch.