处理lambda[duplicate]中检查的异常

Question

我有一些代码抛出一个检查异常。我想在lambda中调用该代码，以便从另一个映射创建一个映射：

Map<String, Coordinate> map = getMap();
Map<String, Integer> result = map.entrySet().stream().collect(
    toMap(x -> x.getKey(), x -> doSomething(x.getValue)));

其中dosometing是引发异常的代码：

int doSomething(Coordinate c) throws MyException { ... }

现在编译器肯定会抱怨没有处理异常。所以我用一个try-catch来包围它，看起来很难看：

Map<String, Integer> result = map.entrySet().stream().collect(
    toMap(x -> x.getKey(), x -> {
        try {
            return doSomething(x.getValue());
        } catch (MyException e) {
            e.printStackTrace();
            // return some error-code here???
        }
    }));

因为我们需要返回catch-case中的内容。然而，在这种例外情况下，返回任何内容都没有多大意义，这就是为什么我实际上不想在该级别处理异常。难道我不能在我创建lambda的调用代码中处理异常吗？所以说只是上面一层？

try {
    Map<String, Integer> result = ...
} catch (MyException e) { ... }

但这无法编译,因为从lambda引发的异常未被处理。

Answer 1

来自Baeldung的博客：您可以定义可以抛出异常的消费者：

@FunctionalInterface
public interface ThrowingConsumer<T, E extends Exception> {
    void accept(T t) throws E;
}

和将检查的异常映射到runtimeexception的静态包装：

static <T> Consumer<T> throwingConsumerWrapper(
  ThrowingConsumer<T, Exception> throwingConsumer) {

    return i -> {
        try {
            throwingConsumer.accept(i);
        } catch (Exception ex) {
            throw new RuntimeException(ex);
        }
    };
}

那么你可以称之为：

Map<String, Integer> result = map.entrySet().stream()
    .collect(
        throwingConsumerWrapper(toMap(x -> x.getKey(), x -> doSomething(x.getValue)))
    );