Uses of Interface
org.apache.flink.util.function.ThrowingConsumer

Packages that use ThrowingConsumer

Package	Description
org.apache.flink.api.common.state.v2
org.apache.flink.util.function

Uses of ThrowingConsumer in org.apache.flink.api.common.state.v2

Methods in org.apache.flink.api.common.state.v2 with parameters of type ThrowingConsumer

Modifier and Type	Method	Description
StateFuture<Void>	StateIterator.onNext(ThrowingConsumer<T,Exception> iterating)	Async iterate the data and call the callback when data is ready.
StateFuture<Void>	StateFuture.thenAccept(ThrowingConsumer<? super T,? extends Exception> action)	Returns a new StateFuture that, when this future completes normally, is executed with this future's result as the argument to the supplied action.
StateFuture<Boolean>	StateFuture.thenConditionallyAccept(FunctionWithException<? super T,Boolean,? extends Exception> condition, ThrowingConsumer<? super T,? extends Exception> actionIfTrue)	Apply a condition test on the result of this StateFuture, and try to perform the action if test result is true.
StateFuture<Boolean>	StateFuture.thenConditionallyAccept(FunctionWithException<? super T,Boolean,? extends Exception> condition, ThrowingConsumer<? super T,? extends Exception> actionIfTrue, ThrowingConsumer<? super T,? extends Exception> actionIfFalse)	Apply a condition test on the result of this StateFuture, and try to perform one action out of two based on the result.

Uses of ThrowingConsumer in org.apache.flink.util.function

Methods in org.apache.flink.util.function with parameters of type ThrowingConsumer

Modifier and Type	Method	Description
static <A> Consumer<A>	ThrowingConsumer.unchecked(ThrowingConsumer<A,?> throwingConsumer)	Convert a ThrowingConsumer into a Consumer.