метательное исключение из лямбда

Question

Учитывая это Java 8 кода

public Server send(String message) { 
    sessions.parallelStream() 
     .map(Session::getBasicRemote) 
     .forEach(basic -> { 
      try { 
      basic.sendText(message); 
      } catch (IOException e) { 
      e.printStackTrace(); 
      } 
     }); 

    return this; 
} 

как мы правильно сделать это IOException быть делегировано стек вызов метода? (В двух словах, как сделать этот метод бросить эту IOException?)

Лямбда в Java не выглядит очень дружественной к обработке ошибок ...

Answer 1

Мой подход был бы украдкой брось от лямбда, но будьте осторожны, чтобы иметь метод send объявить его в пункте throws. Использование Exceptional класса I posted here:

public Server send(String message) throws IOException { 
    sessions.parallelStream() 
      .map(Session::getBasicRemote) 
      .forEach(basic -> Exceptional.from(() -> basic.sendText(message)).get()); 
    return this; 
} 

Таким образом, вы эффективно делает компилятор «Отвернись» для только немного, отключив его исключение проверки в одном месте в коде, но, объявив исключение на ваш send метод, вы восстанавливаете регулярное поведение для всех своих вызывающих абонентов.

Answer 2

Проблема заключается в том, действительно, что все @FunctionalInterface s, используемом в лямбды не допускают исключения быть выброшенным, за исключением исключенных исключений.

Одно решение использует a package of mine; с ним, ваш код может читать:

sessions.parallelStream() 
    .map(Session::getBasicRemote) 
    .forEach(Throwing.consumer(basic -> basic.sendText(message))); 
return this; 

Answer 3

I wrote an extension API Stream, который позволяет проверять исключение, которое должно быть выбрано.

public Server send(String message) throws IOException { 
    ThrowingStream.of(sessions, IOException.class) 
     .parallelStream() 
     .map(Session::getBasicRemote) 
     .forEach(basic -> basic.sendText(message)); 

    return this; 
}