From ad07b5f29b850f3c520ee3fd9168f60df49af89b Mon Sep 17 00:00:00 2001
From: Jaikiran Pai <jaikiran@apache.org>
Date: Sat, 27 Mar 2021 17:57:58 +0530
Subject: [PATCH] bz-64733 junitlauncher - Use the
 org.apache.tools.ant.util.LeadPipeInputStream, which as it states, will not
 cause an error when the writing thread is no longer alive

---
 .../ant/taskdefs/optional/junitlauncher/LauncherSupport.java  | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/src/main/org/apache/tools/ant/taskdefs/optional/junitlauncher/LauncherSupport.java b/src/main/org/apache/tools/ant/taskdefs/optional/junitlauncher/LauncherSupport.java
index d96876d27..fa92393b8 100644
--- a/src/main/org/apache/tools/ant/taskdefs/optional/junitlauncher/LauncherSupport.java
+++ b/src/main/org/apache/tools/ant/taskdefs/optional/junitlauncher/LauncherSupport.java
@@ -30,6 +30,7 @@ import org.apache.tools.ant.taskdefs.optional.junitlauncher.confined.TestClasses
 import org.apache.tools.ant.taskdefs.optional.junitlauncher.confined.TestDefinition;
 import org.apache.tools.ant.util.FileUtils;
 import org.apache.tools.ant.util.KeepAliveOutputStream;
+import org.apache.tools.ant.util.LeadPipeInputStream;
 import org.junit.platform.engine.Filter;
 import org.junit.platform.engine.discovery.DiscoverySelectors;
 import org.junit.platform.launcher.EngineFilter;
@@ -44,7 +45,6 @@ import org.junit.platform.launcher.core.LauncherFactory;
 import org.junit.platform.launcher.listeners.SummaryGeneratingListener;
 import org.junit.platform.launcher.listeners.TestExecutionSummary;
 
-import java.io.Closeable;
 import java.io.IOException;
 import java.io.InputStream;
 import java.io.OutputStream;
@@ -380,7 +380,7 @@ public class LauncherSupport {
         final PipedOutputStream pipedOutputStream = new PipedOutputStream();
         final PipedInputStream pipedInputStream;
         try {
-            pipedInputStream = new PipedInputStream(pipedOutputStream);
+            pipedInputStream = new LeadPipeInputStream(pipedOutputStream);
         } catch (IOException ioe) {
             // log and return
             return Optional.empty();