Uses of Interface
io.fluxzero.common.ThrowingConsumer

Packages that use ThrowingConsumer

Package	Description
io.fluxzero.common
io.fluxzero.sdk
io.fluxzero.sdk.common.serialization
io.fluxzero.sdk.common.serialization.jackson

Uses of ThrowingConsumer in io.fluxzero.common

Methods in io.fluxzero.common that return ThrowingConsumer

Modifier and Type	Method	Description
default ThrowingConsumer<T>	ThrowingConsumer.andThen(@NonNull ThrowingConsumer<? super T> after)	Returns a composed consumer that performs, in sequence, this operation followed by the after operation.

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

Modifier and Type	Method	Description
default ThrowingConsumer<T>	ThrowingConsumer.andThen(@NonNull ThrowingConsumer<? super T> after)	Returns a composed consumer that performs, in sequence, this operation followed by the after operation.
static <T> Consumer<T>	ObjectUtils.asConsumer(ThrowingConsumer<T> consumer)
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.

Uses of ThrowingConsumer in io.fluxzero.sdk

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

Modifier and Type	Method	Description
default void	Fluxzero.execute(ThrowingConsumer<Fluxzero> task)	Executes the given task with this Fluxzero set as current threadlocal instance.

Uses of ThrowingConsumer in io.fluxzero.sdk.common.serialization

Methods in io.fluxzero.sdk.common.serialization with parameters of type ThrowingConsumer

Modifier and Type	Method	Description
static void	DeserializingMessage.whenBatchCompletes(ThrowingConsumer<Throwable> executable)

Uses of ThrowingConsumer in io.fluxzero.sdk.common.serialization.jackson

Methods in io.fluxzero.sdk.common.serialization.jackson with parameters of type ThrowingConsumer

Modifier and Type	Method	Description
void	JacksonContentFilter.FilteringSerializer.serializeAndThen(Object input, com.fasterxml.jackson.core.JsonGenerator jsonGenerator, ThrowingConsumer<Object> followUp)	Invokes the content filter if available and serializes the filtered result.