Uses of Interface
io.fluxzero.common.ThrowingFunction

Packages that use ThrowingFunction

Package	Description
io.fluxzero.common
io.fluxzero.common.api
io.fluxzero.common.search

Uses of ThrowingFunction in io.fluxzero.common

Methods in io.fluxzero.common that return ThrowingFunction

Modifier and Type	Method	Description
default <V> ThrowingFunction<T,V>	ThrowingFunction.andThen(@NonNull ThrowingFunction<? super R, ? extends V> after)	Returns a composed function that first applies this function to its input, and then applies the after function to the result.
default <V> ThrowingFunction<V,R>	ThrowingFunction.compose(@NonNull ThrowingFunction<? super V, ? extends T> before)	Returns a composed function that first applies the before function to its input, and then applies this function to the result.

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

Modifier and Type	Method	Description
default <V> ThrowingBiFunction<T,U,V>	ThrowingBiFunction.andThen(@NonNull ThrowingFunction<? super R, ? extends V> after)	Returns a composed function that first applies this function to its input, and then applies the after function to the result.
default <V> ThrowingFunction<T,V>	ThrowingFunction.andThen(@NonNull ThrowingFunction<? super R, ? extends V> after)	Returns a composed function that first applies this function to its input, and then applies the after function to the result.
static <T,R> Function<T,R>	ObjectUtils.asFunction(ThrowingFunction<T,R> function)
default <V> ThrowingFunction<V,R>	ThrowingFunction.compose(@NonNull ThrowingFunction<? super V, ? extends T> before)	Returns a composed function that first applies the before function to its input, and then applies this function to the result.
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.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.

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

Modifier	Constructor	Description
protected	Backlog(ThrowingFunction<List<T>, CompletableFuture<?>> consumer)
protected	Backlog(ThrowingFunction<List<T>, CompletableFuture<?>> consumer, int maxBatchSize)
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)

Uses of ThrowingFunction in io.fluxzero.common.api

Methods in io.fluxzero.common.api with parameters of type ThrowingFunction

Modifier and Type	Method	Description
<M> Data<M>	Data.map(ThrowingFunction<T,M> mapper)	Transforms the value using a custom mapping function, while preserving serialization metadata.

Uses of ThrowingFunction in io.fluxzero.common.search

Methods in io.fluxzero.common.search that return ThrowingFunction

Modifier and Type	Method	Description
protected static ThrowingFunction<Object,String>	JacksonInverter.createSummarizer(JacksonInverter inverter)