Uses of Interface
io.fluxzero.common.ThrowingFunction

Packages that use ThrowingFunction

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

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, ErrorHandler<List<T>> errorHandler)	Creates a backlog for an asynchronous consumer with custom max batch size and error handler.

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)

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)

Uses of ThrowingFunction in io.fluxzero.sdk

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

Modifier and Type	Method	Description
default <R> R	Fluxzero.apply(ThrowingFunction<Fluxzero,R> function)	Applies the given function with this Fluxzero set as current threadlocal instance.