ブロック外でforeachのコンシューマからRuntimeExceptionをキャッチする方法はありますか？

Question

私は（いくつかのより多くのネストされたforEach'sとstreamsで）いくつかのコードを持っている：

void process() throws RuntimeException 
{ 
    try { 

     ArrayList<Integer> ints = new ArrayList<>(); 
     ints.add(1); 
     ints.add(2); 
     ints.add(3); 

     ints.forEach(e -> { 

      System.out.println(e); 
      throw new RuntimeException("RuntimeException"); 

     }); 
    } 
    catch (RuntimeException rex) 
    { 
     rex.printStackTrace(); 
     throw rex; // throw it up, and up, and up... 
    } 
} 

foreach'sConsumer'saccept()は、デフォルトでは、例外をスローしませんので、それは動作しません。もしそれがthrowsの署名を持っていたとしても、私はブロックの外にそれを捕まえることができませんでした。

私がする必要があるのは、foreach()メソッド自体から例外をキャッチすることです。

は、私はその

void handleException(RuntimeException ex){ ... }

、すべてのforEach()'sのtry/catchでそれを呼び出すようないくつかの外部メソッドずに達成できる方法はありますか？

Answer 1

質問が間違っていることがわかりました。実際にはRuntimeExceptionで動作します。チェック例外のために

が動作するコードです：

package Exporter; 

import java.util.function.Consumer; 
import java.util.function.Function; 

public final class LambdaExceptions { 

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

    @FunctionalInterface 
    public interface Function_WithExceptions<T, R, E extends Exception> { 
     R apply(T t) throws E; 
    } 

    /** 
    * .forEach(rethrowConsumer(name -> System.out.println(Class.forName(name)))); 
    */ 
    public static <T, E extends Exception> Consumer<T> rethrowConsumer(Consumer_WithExceptions<T, E> consumer) throws E { 
     return t -> { 
      try { 
       consumer.accept(t); 
      } catch (Exception exception) { 
       throwActualException(exception); 
      } 
     }; 
    } 

    /** 
    * .map(rethrowFunction(name -> Class.forName(name))) or .map(rethrowFunction(Class::forName)) 
    */ 
    public static <T, R, E extends Exception> Function<T, R> rethrowFunction(Function_WithExceptions<T, R, E> function) throws E { 
     return t -> { 
      try { 
       return function.apply(t); 
      } catch (Exception exception) { 
       throwActualException(exception); 
       return null; 
      } 
     }; 
    } 

    @SuppressWarnings("unchecked") 
    private static <E extends Exception> void throwActualException(Exception exception) throws E { 
     throw (E) exception; 
    } 

} 

そして、それは魔法のように動作します：

void process() throws RuntimeException 
{ 
    try { 
     ArrayList<Integer> ints = new ArrayList<>(); 
     ints.add(1); 
     ints.add(2); 
     ints.add(3); 

     ints.forEach(LambdaExceptions.rethrowConsumer(e -> { 
      System.out.println(e); 
      throw new RuntimeException("RuntimeException"); 
     })); 

    } 
    catch (RuntimeException rex) 
    { 
     System.out.println("Got first exception"); 
     rex.printStackTrace(); 
     throw rex; 
    } 
}