diff --git a/java/java-impl/src/com/intellij/codeInspection/streamMigration/ForEachMigration.java b/java/java-impl/src/com/intellij/codeInspection/streamMigration/ForEachMigration.java
index 316cbb2e2c06..7afff77e159b 100644
--- a/java/java-impl/src/com/intellij/codeInspection/streamMigration/ForEachMigration.java
+++ b/java/java-impl/src/com/intellij/codeInspection/streamMigration/ForEachMigration.java
@@ -25,7 +25,6 @@ import com.intellij.psi.codeStyle.VariableKind;
 import com.siyeh.ig.psiutils.CommentTracker;
 import com.siyeh.ig.psiutils.ExpressionUtils;
 import com.siyeh.ig.psiutils.VariableAccessUtils;
-import org.jetbrains.annotations.Contract;
 import org.jetbrains.annotations.NotNull;
 import org.jetbrains.annotations.Nullable;
 
@@ -90,7 +89,7 @@ class ForEachMigration extends BaseStreamApiMigration {
     String stream = tb.generate(ct, true) + "." + getReplacement() + "(";
     PsiElement block = tb.convertToElement(ct, factory);
 
-    final String functionalExpressionText = tb.getVariable().getName() + " -> " + wrapInBlock(block);
+    final String functionalExpressionText = tb.getVariable().getName() + " -> " + wrapInBlock(ct, block);
     PsiExpressionStatement callStatement =
       (PsiExpressionStatement)ct.replaceAndRestoreComments(loopStatement, stream + functionalExpressionText + ");");
 
@@ -105,20 +104,20 @@ class ForEachMigration extends BaseStreamApiMigration {
       if (typeElement != null) {
         String typedVariable = typeElement.getText() + " " + tb.getVariable().getName();
         callStatement = (PsiExpressionStatement)callStatement.replace(factory.createStatementFromText(
-          stream + "(" + typedVariable + ") -> " + wrapInBlock(block) + ");", callStatement));
+          stream + "(" + typedVariable + ") -> " + wrapInBlock(ct, block) + ");", callStatement));
       }
     }
     return callStatement;
   }
 
-  @Contract("null -> !null")
-  private static String wrapInBlock(PsiElement block) {
+  @NotNull
+  private static String wrapInBlock(@NotNull CommentTracker ct, @NotNull PsiElement block) {
     if (block instanceof PsiExpressionStatement) {
-      return ((PsiExpressionStatement)block).getExpression().getText();
+      return ct.text(((PsiExpressionStatement)block).getExpression());
     }
     if (block instanceof PsiCodeBlock) {
-      return block.getText();
+      return ct.text(block);
     }
-    return "{" + block.getText() + "}";
+    return "{" + ct.text(block) + "}";
   }
 }
diff --git a/java/java-impl/src/com/intellij/codeInspection/streamMigration/TerminalBlock.java b/java/java-impl/src/com/intellij/codeInspection/streamMigration/TerminalBlock.java
index 846f0775a695..d455b4bee43a 100644
--- a/java/java-impl/src/com/intellij/codeInspection/streamMigration/TerminalBlock.java
+++ b/java/java-impl/src/com/intellij/codeInspection/streamMigration/TerminalBlock.java
@@ -469,7 +469,7 @@ class TerminalBlock {
    */
   PsiElement convertToElement(CommentTracker ct, PsiElementFactory factory) {
     if (myStatements.length == 1) {
-      return ct.markUnchanged(myStatements[0]);
+      return myStatements[0];
     }
     PsiCodeBlock block = factory.createCodeBlock();
     for (PsiStatement statement : myStatements) {
diff --git a/java/java-tests/testData/codeInsight/daemonCodeAnalyzer/quickFix/simplifyForEach/afterBlockForEachToForEachComments.java b/java/java-tests/testData/codeInsight/daemonCodeAnalyzer/quickFix/simplifyForEach/afterBlockForEachToForEachComments.java
index e671a43190bd..3b2a31851afc 100644
--- a/java/java-tests/testData/codeInsight/daemonCodeAnalyzer/quickFix/simplifyForEach/afterBlockForEachToForEachComments.java
+++ b/java/java-tests/testData/codeInsight/daemonCodeAnalyzer/quickFix/simplifyForEach/afterBlockForEachToForEachComments.java
@@ -6,7 +6,7 @@ public class Main {
   private void test() {
     List<String> other = new ArrayList<>();
       // c1
-//c2
+      //c2
       other.stream().filter(s -> s.length() > 2).forEach(System.out::println);
   }
 }