[ant] branch master updated: 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

[ja...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

jaikiran pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ant.git


The following commit(s) were added to refs/heads/master by this push:
     new ad07b5f  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
ad07b5f is described below

commit ad07b5f29b850f3c520ee3fd9168f60df49af89b
Author: Jaikiran Pai <ja...@apache.org>
AuthorDate: Sat Mar 27 17:57:58 2021 +0530

    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
---
 .../tools/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 d96876d..fa92393 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();