Reword it

Author: cstamas

impl/maven-executor/src/main/java/org/apache/maven/cling/executor/forked/ForkedMavenExecutor.java

@@ -20,6 +20,8 @@
 
 import java.io.ByteArrayOutputStream;
 import java.io.IOException;
+import java.io.InputStream;
+import java.io.OutputStream;
 import java.io.UncheckedIOException;
 import java.nio.file.Files;
 import java.nio.file.Path;
@@ -107,9 +109,9 @@ protected Consumer<Process> wrapRequestStandardStreams(ExecutorRequest executorR
                 String suffix = "-pump-" + p.pid();
                 executorRequest.stdOut().ifPresent(stdout -> {
                     Thread pump = new Thread(() -> {
-                        try {
+                        try (InputStream out = p.getInputStream()) {
                             int c;
-                            while ((c = p.getInputStream().read()) != -1) {
+                            while ((c = out.read()) != -1) {
                                 stdout.write(c);
                             }
                             stdout.flush();
@@ -123,9 +125,9 @@ protected Consumer<Process> wrapRequestStandardStreams(ExecutorRequest executorR
                 });
                 executorRequest.stdErr().ifPresent(stderr -> {
                     Thread pump = new Thread(() -> {
-                        try {
+                        try (InputStream err = p.getErrorStream()) {
                             int c;
-                            while ((c = p.getErrorStream().read()) != -1) {
+                            while ((c = err.read()) != -1) {
                                 stderr.write(c);
                             }
                             stderr.flush();
@@ -139,12 +141,12 @@ protected Consumer<Process> wrapRequestStandardStreams(ExecutorRequest executorR
                 });
                 executorRequest.stdIn().ifPresent(stdin -> {
                     Thread pump = new Thread(() -> {
-                        try {
+                        try (OutputStream in = p.getOutputStream()) {
                             int c;
                             while ((c = stdin.read()) != -1) {
-                                p.getOutputStream().write(c);
+                                in.write(c);
                             }
-                            p.getOutputStream().flush();
+                            in.flush();
                         } catch (IOException e) {
                             throw new UncheckedIOException(e);
                         }
@@ -205,6 +207,7 @@ protected int doExecute(ExecutorRequest executorRequest, Consumer<Process> proce
         try {
             ProcessBuilder pb = new ProcessBuilder()
                     .directory(executorRequest.cwd().toFile())
+                    .inheritIO()
                     .command(cmdAndArguments);
             if (!env.isEmpty()) {
                 pb.environment().putAll(env);