java - ラムダからの例外のスロー

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

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

チェック済みの例外をスローできるようにする Stream APIの拡張機能を作成しました。

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

    return this;
}

Answer 3

実際問題は、ラムダで使用されるすべて@FunctionalInterfaceの s が例外のスローを許可しないことです。未チェックの例外を除きます。

1 つの解決策は、私のパッケージを使用することです。それを使用すると、コードは次のようになります。

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