Package org.apache.flink.util.concurrent

Interface FutureConsumerWithException<T,E extends Throwable>

Type Parameters:

T - type of the first argument

E - type of the thrown exception

All Superinterfaces:

Consumer<T>

public interface FutureConsumerWithException<T,E extends Throwable>
extends Consumer<T>

A checked extension of the Consumer interface which rethrows exceptions wrapped in a CompletionException.

Method Summary

Modifier and Type	Method	Description
default void	accept(T value)
void	acceptWithException(T value)

Methods inherited from interface java.util.function.Consumer

andThen

Method Detail

acceptWithException

void acceptWithException(T value)
                  throws E extends Throwable

Throws:

E extends Throwable

accept

default void accept(T value)

Specified by:

accept in interface Consumer<T>