Uses of Interface
io.fluxcapacitor.common.ThrowingFunction
Packages that use ThrowingFunction
Package
Description
-
Uses of ThrowingFunction in io.fluxcapacitor.common
Methods in io.fluxcapacitor.common that return ThrowingFunctionModifier and TypeMethodDescriptiondefault <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 theafter
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 thebefore
function to its input, and then applies this function to the result.Methods in io.fluxcapacitor.common with parameters of type ThrowingFunctionModifier and TypeMethodDescriptiondefault <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 theafter
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 theafter
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 thebefore
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.fluxcapacitor.common with parameters of type ThrowingFunctionModifierConstructorDescriptionprotected
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.fluxcapacitor.common.api
Methods in io.fluxcapacitor.common.api with parameters of type ThrowingFunctionModifier and TypeMethodDescription<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.fluxcapacitor.common.search
Methods in io.fluxcapacitor.common.search that return ThrowingFunctionModifier and TypeMethodDescriptionprotected static ThrowingFunction
<Object, String> JacksonInverter.createSummarizer
(JacksonInverter inverter) -
Uses of ThrowingFunction in io.fluxcapacitor.javaclient
Methods in io.fluxcapacitor.javaclient with parameters of type ThrowingFunctionModifier and TypeMethodDescriptiondefault <R> R
FluxCapacitor.apply
(ThrowingFunction<FluxCapacitor, R> function) Applies the given function with this Flux Capacitor set as current threadlocal instance.