ThrowingStreamを使ってみる

ThrowingStreamについて

Java 8で追加されたStream APIのfilterやmapなどのメソッドでは、チェック例外（Exceptionの派生クラス）をスローするような処理は書けませんが、面白いAPIを見つけました。

• JeffreyFalgout/ThrowingStream

このAPIを使ってみました。

サンプルのAクラス

変なサンプルですが、Aクラスを用意します。

A.java

class A {
    public static String s2(String s) throws IOException {
        if("a".equals(s)){
            throw new IOException("Bad!");
        }
        return s + s;
    }
    public static String s3(String s) {
        return s + s + s;
    }
}

通常のStream APIを使うと…

A#s2()はIOExceptionをスローするため、次のように書く必要があり、コードが読みづらいです。

java

    Stream.of("a", "b")
        .map(s->{
            try{
                return A.s2(s);
            }catch(IOException e){
                throw new UncheckedIOException(e);
            }
        }).forEach(System.out::println);

ThrowingStreamを使うと…

ThrowingStreamを使うと、次のようにコードがすっきりします。

java

    try {
        ThrowingStream.of(Stream.of("a", "b"), IOException.class)
            .map(A::s2)
            .forEach(System.out::println);
    } catch (IOException ex) {
        ex.printStackTrace(System.err);
    }

ThrowingFunctionを活用してみる…

次は、A#s2()の呼び出しでIOExceptionがスローされたら、代わりにA#s3()を呼び出すコードです。
try～catchを使わないのが特徴ですが、可読性はどうなんですかね…

java

class B {
    public static String go(String s){
        final ThrowingFunction<String, String, IOException> func = A::s2;
        return func.fallbackTo(A::s3).apply(s);
    }
}

B.go("a") を実行すると、 aaa が返ってきます。
例外の出力は一切ありません。