in src/main/java/software/amazon/event/kafkaconnector/util/ThrowingFunction.java [14:22]
static <T, R> Function<T, R> wrap(ThrowingFunction<T, R> f) {
return t -> {
try {
return f.apply(t);
} catch (Throwable e) {
throw new ThrowingFunctionApplyException(e);
}
};
}