From 068d20bdea1ac6f525609297e7fec14a341a2040 Mon Sep 17 00:00:00 2001
From: Slawomir Jaranowski <s.jaranowski@gmail.com>
Date: Fri, 21 Apr 2023 19:54:40 +0200
Subject: [PATCH] Interrupt Feeder thread not current thread

---
 .../maven/shared/utils/cli/StreamFeeder.java  |  2 +-
 .../shared/utils/cli/StreamFeederTest.java    | 23 +++++++------------
 2 files changed, 9 insertions(+), 16 deletions(-)

diff --git a/src/main/java/org/apache/maven/shared/utils/cli/StreamFeeder.java b/src/main/java/org/apache/maven/shared/utils/cli/StreamFeeder.java
index f3b595ef..f26db634 100644
--- a/src/main/java/org/apache/maven/shared/utils/cli/StreamFeeder.java
+++ b/src/main/java/org/apache/maven/shared/utils/cli/StreamFeeder.java
@@ -89,7 +89,7 @@ public Throwable getException() {
     }
 
     public void waitUntilDone() {
-        interrupt();
+        this.interrupt();
         synchronized (lock) {
             while (!done) {
                 try {
diff --git a/src/test/java/org/apache/maven/shared/utils/cli/StreamFeederTest.java b/src/test/java/org/apache/maven/shared/utils/cli/StreamFeederTest.java
index fb17acb9..79fea0ed 100644
--- a/src/test/java/org/apache/maven/shared/utils/cli/StreamFeederTest.java
+++ b/src/test/java/org/apache/maven/shared/utils/cli/StreamFeederTest.java
@@ -46,9 +46,6 @@
 
 public class StreamFeederTest {
     static class BlockingInputStream extends ByteArrayInputStream {
-        boolean endStream = false;
-        final Object lock = new Object();
-
         public BlockingInputStream(byte[] buf) {
             super(buf);
         }
@@ -61,8 +58,6 @@ public synchronized int read() {
             }
 
             // end test data ... block
-            endStream = true;
-
             try {
                 wait();
             } catch (InterruptedException e) {
@@ -70,29 +65,27 @@ public synchronized int read() {
             }
             return -1;
         }
-
-        public synchronized void waitForEndStream() throws InterruptedException {
-            while (!endStream) {
-                wait(100);
-            }
-        }
     }
 
     @Test
     public void waitUntilFeederDone() throws InterruptedException {
 
-        BlockingInputStream inputStream = new BlockingInputStream("TestData".getBytes());
+        String TEST_DATA = "TestData";
+
+        BlockingInputStream inputStream = new BlockingInputStream(TEST_DATA.getBytes());
         ByteArrayOutputStream outputStream = new ByteArrayOutputStream();
 
         StreamFeeder streamFeeder = new StreamFeeder(inputStream, outputStream);
 
         streamFeeder.start();
 
-        // wait until input stream will be in block mode
-        inputStream.waitForEndStream();
+        // wait until all data from steam will be read
+        while (outputStream.size()<TEST_DATA.length()) {
+            Thread.sleep(10);
+        }
 
         streamFeeder.waitUntilDone(); // wait until process finish
 
-        assertEquals("TestData", outputStream.toString());
+        assertEquals(TEST_DATA, outputStream.toString());
     }
 }