[解決済み] Java 8: ラムダストリーム、例外を含むメソッドによるフィルタリング

質問

Java 8のLambda式を試していて、問題が発生しました。 通常は問題なく動作するのですが、現在、以下のようなメソッドがあります。 IOException 's. 以下のコードを見ていただければと思います。

class Bank{
    ....
    public Set<String> getActiveAccountNumbers() throws IOException {
        Stream<Account> s =  accounts.values().stream();
        s = s.filter(a -> a.isActive());
        Stream<String> ss = s.map(a -> a.getNumber());
        return ss.collect(Collectors.toSet());
    }
    ....
}

interface Account{
    ....
    boolean isActive() throws IOException;
    String getNumber() throws IOException;
    ....
}

問題は、isActiveメソッドとgetNumberメソッドで起こりうる例外をキャッチしなければならないので、コンパイルできないことです。しかし、以下のように明示的にtry-catch-blockを使用しても、Exceptionをcatchしていないため、まだコンパイルされない。つまり、JDKにバグがあるのか、私がこれらのExceptionをキャッチする方法を知らないのか、どちらかです。

class Bank{
    ....
    //Doesn't compile either
    public Set<String> getActiveAccountNumbers() throws IOException {
        try{
            Stream<Account> s =  accounts.values().stream();
            s = s.filter(a -> a.isActive());
            Stream<String> ss = s.map(a -> a.getNumber());
            return ss.collect(Collectors.toSet());
        }catch(IOException ex){
        }
    }
    ....
}

どうすれば動くようになるのでしょうか？どなたか、正しい解決策をヒントにしていただけませんか？

解決方法は？

例外をキャッチする必要があります。 前に がラムダをエスケープします。

s = s.filter(a -> {
    try {
        return a.isActive();
    } catch (IOException e) {
        throw new UncheckedIOException(e);
    }
});

ラムダが評価されるのは、あなたが書いた場所ではなく、JDKのクラス内の全く関係のない場所であるという事実を考えてみてください。そこでチェックされた例外が投げられることになるのだが、その場所では宣言されていない。

チェックされた例外をチェックされていない例外に変換するラムダのラッパーを使うことで、この問題に対処できます。

public static <T> T uncheckCall(Callable<T> callable) {
    try {
        return callable.call();
    } catch (RuntimeException e) {
        throw e;
    } catch (Exception e) {
        throw new RuntimeException(e);
    }
}

あなたの例は次のように書かれます。

return s.filter(a -> uncheckCall(a::isActive))
        .map(Account::getNumber)
        .collect(toSet());

私のプロジェクトでは、この問題をラップせずに、コンパイラによる例外チェックを効果的に無効化する方法を用いて対処しています。言うまでもなく、これは慎重に扱うべきもので、プロジェクトに参加する誰もが、宣言されていないところでチェックされた例外が現れる可能性があることを認識しておく必要があります。これがそのコードです。

public static <T> T uncheckCall(Callable<T> callable) {
    try {
        return callable.call();
    } catch (Exception e) {
        return sneakyThrow(e);
    }
}

public static void uncheckRun(RunnableExc r) {
    try {
        r.run();
    } catch (Exception e) {
        sneakyThrow(e);
    }
}

public interface RunnableExc {
    void run() throws Exception;
}

@SuppressWarnings("unchecked")
private static <T extends Throwable> void sneakyThrow(Throwable t) throws T {
    throw (T) t;
}

を取得することが期待できます。 IOException を投げつけても collect はそれを宣言していない。で ほとんど、しかしすべてではない 現実のケースでは、とにかく例外を再スローして、一般的な失敗として処理したいと思うでしょう。このような場合、明快さや正しさは何も失われません。ただ、例外にその場で対応したくなるようなケースには注意が必要です。開発者は、コンパイラによって IOException をキャッチしようとすると、コンパイラは文句を言うでしょう。なぜなら、そのような例外は投げられないと信じ込ませてしまったからです。