Lanciare da lambda

Question

Dato questo java 8 codice

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

    return this; 
} 

come possiamo correttamente facciamo questa IOException essere delegato lo stack della chiamata al metodo? (In poche parole come rendere questo metodo di gettare questo IOException?)

Lambda in java non sembra molto amichevole per gestione degli errori ...

Answer 1

Il mio approccio sarebbe quello di subdolamente tiro dalla lambda, ma fate attenzione ad avere il metodo send dichiararla nella sua throws clausola. Utilizzando la classe ExceptionalI posted here:

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

In questo modo si sta effettivamente facendo il compilatore "guardare lontano" solo per un po ', disabilitando le sue eccezioni controllo in un punto nel codice, ma dichiarando l'eccezione sul vostro send metodo, si ripristina il comportamento normale per tutti i suoi chiamanti.

Answer 2

Il problema è infatti che tutti i @FunctionalInterface s utilizzati in lambda Non consentire eccezioni da lanciare, salvo eccezioni non controllate.

Una soluzione utilizza a package of mine; con esso, il codice può leggere:

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

Answer 3

I wrote an extension all'API Stream che consente di generare eccezioni controllate.

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

    return this; 
}