Throwing Ausnahme von Lambda

Question

diesen Java-8 Code Gegeben

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

    return this; 
} 

wie richtig machen wir dies den Stapel des Methodenaufrufes delegiert werden IOException? (In aller Kürze, wie diese Methode machen diese IOException werfen?)

Lambdas in Java nicht sehr freundlich sehen Umgang mit dem Irrtum ...

Answer 1

Mein Ansatz es sneakily Wurf vom Lambda sein würde, aber darauf achten, die send Methode es in seiner throws Klausel erklären zu lassen. Mit Hilfe der Exceptional Klasse 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; 
} 

Auf diese Weise sind Sie effektiv den Compiler zu machen „wegschauen“ für nur ein bisschen, zu deaktivieren seine Ausnahme an einer Stelle überprüft im Code, sondern die Ausnahme auf Ihrem send erklärt Mit dieser Methode stellen Sie das normale Verhalten für alle Aufrufer wieder her.

Answer 2

Das Problem ist in der Tat, dass alle @FunctionalInterface s in lambdas verwendet werden, keine Ausnahmen zulassen geworfen werden, außer für ungeprüfte Ausnahmen.

Eine Lösung verwendet a package of mine; mit ihm können Sie den Code lesen:

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

Answer 3

I an die Stream-API, die es ermöglicht, dass überprüfte Ausnahmen ausgelöst werden.

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

    return this; 
}