java 8ストリーム内で例外をスローするforeach

Question

私はJava 8ストリームを使用しています。ストリームのforeach内で例外をスローすることはできません。

stream.forEach(m -> { 
     try { 

      if (isInitial) { 
       isInitial = false; 
       String outputName = new SimpleDateFormat(Constants.HMDBConstants.HMDB_SDF_FILE_NAME).format(new Date()); 
       if (location.endsWith(Constants.LOCATION_SEPARATOR)) { 
        savedPath = location + outputName; 
       } else { 
        savedPath = location + Constants.LOCATION_SEPARATOR + outputName; 
       } 
       File output = new File(savedPath); 
       FileWriter fileWriter = null; 
       fileWriter = new FileWriter(output); 
       writer = new SDFWriter(fileWriter); 
      } 

      writer.write(m); 

     } catch (IOException e) { 
      throw new ChemIDException(e.getMessage(),e); 
     } 

    }); 

、これは私が上位レベルのエラーをログに記録するロガーを使用しています

public class ChemIDException extends Exception { 
public ChemIDException(String message, Exception e) { 
    super(message, e); 
} 

}

私の例外クラスです。だから私は例外を上に投げたい。おかげ

Answer 1

ではなくRuntimeExceptionを拡張してみます。 foreachにフィードするために作成されたメソッドは、その型をスロー可能として持たないため、実行時にスロー可能なものが必要です。

警告：これはおそらく非常に良いアイデア

はありませんが、それはおそらく動作します。

Answer 2

は、なぜあなたは、あなたがしたいすべてが、最初要素を処理するときに、すべてのの要素を処理するために設計された方法をforEach使用していますか？ forEachが仕事のための間違った方法であることを理解する代わりに（forEachよりもStream APIに多くのメソッドがあります）、これをisInitialフラグでkludgingしています。

だけで考えてみます。例外処理では問題がありません

Optional<String> o = stream.findFirst(); 
if(o.isPresent()) try { 
    String outputName = new SimpleDateFormat(Constants.HMDBConstants.HMDB_SDF_FILE_NAME) 
         .format(new Date()); 
    if (location.endsWith(Constants.LOCATION_SEPARATOR)) { 
     savedPath = location + outputName; 
    } else { 
     savedPath = location + Constants.LOCATION_SEPARATOR + outputName; 
    } 
    File output = new File(savedPath); 
    FileWriter fileWriter = null; 
    fileWriter = new FileWriter(output); 
    writer = new SDFWriter(fileWriter); 
    writer.write(o.get()); 
} catch (IOException e) { 
    throw new ChemIDException(e.getMessage(),e); 
} 

を。この例では、Streamの要素タイプがStringであることを前提としています。それ以外の場合は、Optional<String>タイプを適合させる必要があります。しかし、あなたのisInitialフラグはストリーム処理中に複数回変更することになって、場合

---

、あなたの仕事のための間違ったツールを使用して間違いです。 Streamsを使用する前に、“Non-interference” sectionと同様に、Stream APIドキュメントの“Stateless behaviors” and “Side-effects” sectionsを読んで理解しておく必要があります。ストリームの呼び出しをforEach呼び出しに変換しても、コードは改善されません。