[maven-release-plugin] prepare release gclc-2.0.1

Signed-off-by: Emmanuel Bigeon <emmanuel@bigeon.fr>

gclc-process/pom.xml

@@ -54,7 +54,7 @@
     <dependency>
       <groupId>fr.bigeon</groupId>
       <artifactId>gclc</artifactId>
-      <version>2.0.0-SNAPSHOT</version>
+      <version>2.0.0</version>
     </dependency>
   </dependencies>
 </project>

gclc-socket/pom.xml

@@ -81,12 +81,12 @@ of Emmanuel Bigeon.                                                   -->
     <dependency>
     	<groupId>fr.bigeon</groupId>
     	<artifactId>gclc</artifactId>
-    	<version>1.5.0</version>
+    	<version>2.0.0</version>
     </dependency>
     <dependency>
     	<groupId>fr.bigeon</groupId>
     	<artifactId>smu</artifactId>
-    	<version>0.0.5</version>
+    	<version>0.0.7</version>
     </dependency>
   </dependencies>
   <parent>

gclc-socket/src/main/java/fr/bigeon/gclc/socket/SocketConsoleApplicationShell.java

@@ -47,8 +47,8 @@ import java.util.logging.Level;
 import java.util.logging.Logger;
 
 import fr.bigeon.gclc.ConsoleApplication;
-import fr.bigeon.gclc.manager.ConsoleManager;
-import fr.bigeon.gclc.manager.PipedConsoleManager;
+import fr.bigeon.gclc.manager.PipedConsoleInput;
+import fr.bigeon.gclc.manager.PipedConsoleOutput;
 import fr.bigeon.gclc.manager.ReadingRunnable;
 
 /** This is a socket communicating console consoleManager
@@ -76,17 +76,17 @@ public class SocketConsoleApplicationShell implements Runnable, AutoCloseable {
      * @author Emmanuel Bigeon */
     private final class OutputForwardRunnable implements Runnable {
         /**
-         * 
+         *
          */
         private final PrintWriter writer;
         /**
-         * 
+         *
          */
         private final Socket socket;
 
         /** @param writer the writer
          * @param socket the socket */
-        protected OutputForwardRunnable(PrintWriter writer, Socket socket) {
+        protected OutputForwardRunnable(final PrintWriter writer, final Socket socket) {
             this.writer = writer;
             this.socket = socket;
         }
@@ -96,16 +96,16 @@ public class SocketConsoleApplicationShell implements Runnable, AutoCloseable {
         public void run() {
             try {
                 while (!socket.isClosed()) {
-                    while (!socket.isClosed() && !consoleManager.available()) {
+                    while (!socket.isClosed() && !output.available()) {
                         waitASec();
                     }
                     if (socket.isClosed()) {
                         return;
                     }
-                    String m = consoleManager.readNextLine();
+                    final String m = output.readNextLine();
                     writer.println(m);
                 }
-            } catch (IOException e) {
+            } catch (final IOException e) {
                 LOGGER.log(Level.SEVERE, "Unexpected problem in manager", //$NON-NLS-1$
                         e);
             }
@@ -129,8 +129,6 @@ public class SocketConsoleApplicationShell implements Runnable, AutoCloseable {
     /** The running status */
     private boolean running;
 
-    /** The console manager implementation */
-    private final PipedConsoleManager consoleManager;
     /** The auto close flag. if this is true, every request closes the session
      * after its call */
     private final boolean autoClose;
@@ -140,25 +138,8 @@ public class SocketConsoleApplicationShell implements Runnable, AutoCloseable {
     private final String applicationShutdown;
     /** The charset for the communication. */
     private final Charset charset;
-
-    /** Create a socket application shell which will listen on the given port
-     * and close session upon the provided string reception by client
-     *
-     * @param port the port to listen to
-     * @param close the session closing command
-     * @param applicationShutdown the appication shut down command
-     * @param charset the charset for communication
-     * @throws IOException if the manager could not be created */
-    public SocketConsoleApplicationShell(int port, String close,
-            String applicationShutdown, Charset charset) throws IOException {
-        this.port = port;
-        this.close = close;
-        this.applicationShutdown = applicationShutdown;
-        this.autoClose = false;
-        this.charset = charset;
-        //
-        consoleManager = new PipedConsoleManager();
-    }
+    private final PipedConsoleOutput output;
+    private final PipedConsoleInput input;
 
     /** Create a socket application shell which will listen on the given port
      * and auto close session after one instruction
@@ -169,15 +150,157 @@ public class SocketConsoleApplicationShell implements Runnable, AutoCloseable {
      * @param applicationShutdown the appication shut down command
      * @param charset the charset for communication
      * @throws IOException if the manager could not be created */
-    public SocketConsoleApplicationShell(int port, boolean autoClose,
-            String applicationShutdown, Charset charset) throws IOException {
+    public SocketConsoleApplicationShell(final int port, final boolean autoClose,
+            final String applicationShutdown, final Charset charset) throws IOException {
         this.port = port;
         this.autoClose = autoClose;
         this.applicationShutdown = applicationShutdown;
-        this.close = autoClose ? null : "close"; //$NON-NLS-1$
+        close = autoClose ? null : "close"; //$NON-NLS-1$
         this.charset = charset;
         //
-        consoleManager = new PipedConsoleManager();
+        output = new PipedConsoleOutput();
+        input = new PipedConsoleInput();
+    }
+
+    /** Create a socket application shell which will listen on the given port
+     * and close session upon the provided string reception by client
+     *
+     * @param port the port to listen to
+     * @param close the session closing command
+     * @param applicationShutdown the appication shut down command
+     * @param charset the charset for communication
+     * @throws IOException if the manager could not be created */
+    public SocketConsoleApplicationShell(final int port, final String close,
+            final String applicationShutdown, final Charset charset) throws IOException {
+        this.port = port;
+        this.close = close;
+        this.applicationShutdown = applicationShutdown;
+        autoClose = false;
+        this.charset = charset;
+        //
+        output = new PipedConsoleOutput();
+        input = new PipedConsoleInput();
+    }
+
+    /* (non-Javadoc)
+     * @see java.lang.AutoCloseable#close() */
+    @Override
+    public void close() throws IOException {
+        input.close();
+        output.close();
+    }
+
+    /** Close the console manager after writing the application shutdown
+     * command.
+     *
+     * @param appThNext the thread containing the application
+     * @throws IOException if the typyng or closing failed */
+    private void closeManager(final Thread appThNext) throws IOException {
+        input.type(applicationShutdown);
+        try {
+            appThNext.join(ONE_TENTH_OF_SECOND);
+        } catch (final InterruptedException e) {
+            LOGGER.warning("Application thread was interrupted!"); //$NON-NLS-1$
+            LOGGER.log(Level.FINE,
+                    "Application thread was interrupted while closing", //$NON-NLS-1$
+                    e);
+        }
+        close();
+    }
+
+    /** active communication between server and client
+     *
+     * @param socket the socket
+     * @param writer the writer to the application
+     * @param in the input from the client
+     * @throws IOException if the communication failed */
+    private void communicate(final Socket socket, final PrintWriter writer,
+                             final BufferedReader in) throws IOException {
+        final OutputForwardRunnable cc = new OutputForwardRunnable(writer, socket);
+        final Thread th = new Thread(cc, "ClientComm"); //$NON-NLS-1$
+        th.start();
+        if (autoClose) {
+            communicateOnce(in);
+        } else {
+            communicateLoop(in);
+        }
+    }
+
+    /** @param in the input from the client
+     * @throws IOException if the communication failed */
+    private void communicateLoop(final BufferedReader in) throws IOException {
+        final ReadingRunnable reading = new ReadingRunnable(in);
+        final Thread th = new Thread(reading, "gclcToApp"); //$NON-NLS-1$
+        th.start();
+        while (app.isRunning() && communicationContent(reading)) {
+            // keep on going
+        }
+        doEndCommunication(reading);
+    }
+
+    /** @param in the input from the client
+     * @throws IOException if the communication failed */
+    private void communicateOnce(final BufferedReader in) throws IOException {
+        final ReadingRunnable reading = new ReadingRunnable(in);
+        final Thread th = new Thread(reading, "gclcToApp"); //$NON-NLS-1$
+        th.start();
+        communicationContent(reading);
+        doEndCommunication(reading);
+    }
+
+    /** @param reading the reading
+     * @return if the communication should be stopped.
+     * @throws IOException if the reading failed */
+    private boolean communicationContent(final ReadingRunnable reading) throws IOException {
+        try {
+            while (app.isRunning() && !reading.hasMessage()) {
+                synchronized (this) {
+                    waitASec();
+                }
+            }
+        } catch (final IOException e) {
+            LOGGER.warning("Client seems dead. Closing communication"); //$NON-NLS-1$
+            LOGGER.log(Level.FINE, "Wait on message from client failed", e); //$NON-NLS-1$
+            return false;
+        }
+        if (!app.isRunning()) {
+            return false;
+        }
+        final String ln = reading.getMessage();
+        if (ln.equals(close)) {
+            return false;
+        }
+        // Pass command to application
+        input.type(ln);
+        return true;
+    }
+
+    /** @param reading the reading runnable
+     * @throws IOException if the end of communication failed */
+    private void doEndCommunication(final ReadingRunnable reading) throws IOException {
+        reading.setRunning(false);
+        final Thread wait = output.getWaitForDelivery("Bye."); //$NON-NLS-1$
+        output.println("Bye."); //$NON-NLS-1$
+        try {
+            wait.join();
+        } catch (final InterruptedException e) {
+            LOGGER.warning("The Bye wait was interrupted."); //$NON-NLS-1$
+            LOGGER.log(Level.FINE, "An interruption occured", e); //$NON-NLS-1$
+        }
+    }
+
+    /**
+     * @return the input
+     */
+    public PipedConsoleInput getInput() {
+        return input;
+    }
+
+    /**
+     * @return the output
+     */
+    public PipedConsoleOutput getOutput() {
+        return output;
     }
 
     /* (non-Javadoc)
@@ -186,7 +309,7 @@ public class SocketConsoleApplicationShell implements Runnable, AutoCloseable {
     public void run() {
         // Create the server
         try (ServerSocket actualServerSocket = new ServerSocket(port)) {
-            this.serverSocket = actualServerSocket;
+            serverSocket = actualServerSocket;
             running = true;
             // Create the streams
             runSokectServer();
@@ -200,7 +323,7 @@ public class SocketConsoleApplicationShell implements Runnable, AutoCloseable {
     /** @throws IOException if the communication with the client failed */
     private void runSokectServer() throws IOException {
         final ConsoleRunnable runnable = new ConsoleRunnable(app);
-        Thread appThNext = new Thread(runnable, "gclc-ctrl"); //$NON-NLS-1$
+        final Thread appThNext = new Thread(runnable, "gclc-ctrl"); //$NON-NLS-1$
         appThNext.start();
         while (running) {
             LOGGER.info("Waiting client"); //$NON-NLS-1$
@@ -221,15 +344,15 @@ public class SocketConsoleApplicationShell implements Runnable, AutoCloseable {
                 } else {
                     LOGGER.info("Reconnect to application"); //$NON-NLS-1$
                     out.println("Reconnected"); //$NON-NLS-1$
-                    out.println(consoleManager.getPrompt());
+                    out.println(input.getPrompt());
                 }
                 communicate(clientSocket, out, in);
-            } catch (SocketException e) {
+            } catch (final SocketException e) {
                 LOGGER.log(Level.INFO, "Socket closed"); //$NON-NLS-1$
                 LOGGER.log(Level.FINE,
                         "Socket closed with exception (probably due to server interruption)", //$NON-NLS-1$
                         e);
-            } catch (IOException e) {
+            } catch (final IOException e) {
                 throw e;
             }
             LOGGER.info("Closing client"); //$NON-NLS-1$
@@ -237,7 +360,7 @@ public class SocketConsoleApplicationShell implements Runnable, AutoCloseable {
         runnable.setRunning(false);
         try {
             closeManager(appThNext);
-        } catch (IOException e) {
+        } catch (final IOException e) {
             LOGGER.warning("Unable to close application correctly"); //$NON-NLS-1$
             LOGGER.log(Level.FINE, "Application closing caused an exception", //$NON-NLS-1$
                     e);
@@ -245,128 +368,24 @@ public class SocketConsoleApplicationShell implements Runnable, AutoCloseable {
         LOGGER.info("Closing Server"); //$NON-NLS-1$
     }
 
-    /** Close the console manager after writing the application shutdown
-     * command.
-     * 
-     * @param appThNext the thread containing the application
-     * @throws IOException if the typyng or closing failed */
-    private void closeManager(Thread appThNext) throws IOException {
-        consoleManager.type(applicationShutdown);
-        try {
-            appThNext.join(ONE_TENTH_OF_SECOND);
-        } catch (InterruptedException e) {
-            LOGGER.warning("Application thread was interrupted!"); //$NON-NLS-1$
-            LOGGER.log(Level.FINE,
-                    "Application thread was interrupted while closing", //$NON-NLS-1$
-                    e);
-        }
-        consoleManager.close();
+    /** @param app the application to set */
+    public synchronized void setApplication(final ConsoleApplication app) {
+        this.app = app;
     }
 
     /** @param runnable the runnable */
-    private void startApplication(ConsoleRunnable runnable) {
+    private void startApplication(final ConsoleRunnable runnable) {
         runnable.restart();
         synchronized (this) {
             try {
                 wait(ONE_TENTH_OF_SECOND);
-            } catch (InterruptedException e) {
+            } catch (final InterruptedException e) {
                 LOGGER.log(Level.SEVERE, "Interruption in application start", //$NON-NLS-1$
                         e);
             }
         }
     }
 
-    /** active communication between server and client
-     * 
-     * @param socket the socket
-     * @param writer the writer to the application
-     * @param in the input from the client
-     * @throws IOException if the communication failed */
-    private void communicate(final Socket socket, final PrintWriter writer,
-                             BufferedReader in) throws IOException {
-        OutputForwardRunnable cc = new OutputForwardRunnable(writer, socket);
-        Thread th = new Thread(cc, "ClientComm"); //$NON-NLS-1$
-        th.start();
-        if (autoClose) {
-            communicateOnce(in);
-        } else {
-            communicateLoop(in);
-        }
-    }
-
-    /** @param in the input from the client
-     * @throws IOException if the communication failed */
-    private void communicateOnce(BufferedReader in) throws IOException {
-        ReadingRunnable reading = new ReadingRunnable(in);
-        Thread th = new Thread(reading, "gclcToApp"); //$NON-NLS-1$
-        th.start();
-        communicationContent(reading);
-        doEndCommunication(reading);
-    }
-
-    /** @param reading the reading runnable
-     * @throws IOException if the end of communication failed */
-    private void doEndCommunication(ReadingRunnable reading) throws IOException {
-        reading.setRunning(false);
-        Thread wait = consoleManager.getWaitForDelivery("Bye."); //$NON-NLS-1$
-        consoleManager.println("Bye."); //$NON-NLS-1$
-        try {
-            wait.join();
-        } catch (InterruptedException e) {
-            LOGGER.warning("The Bye wait was interrupted."); //$NON-NLS-1$
-            LOGGER.log(Level.FINE, "An interruption occured", e); //$NON-NLS-1$
-        }
-    }
-
-    /** @param in the input from the client
-     * @throws IOException if the communication failed */
-    private void communicateLoop(BufferedReader in) throws IOException {
-        ReadingRunnable reading = new ReadingRunnable(in);
-        Thread th = new Thread(reading, "gclcToApp"); //$NON-NLS-1$
-        th.start();
-        while (app.isRunning() && communicationContent(reading)) {
-            // keep on going
-        }
-        doEndCommunication(reading);
-    }
-
-    /** @param reading the reading
-     * @return if the communication should be stopped.
-     * @throws IOException if the reading failed */
-    private boolean communicationContent(ReadingRunnable reading) throws IOException {
-        try {
-            while (app.isRunning() && !reading.hasMessage()) {
-                synchronized (this) {
-                    waitASec();
-                }
-            }
-        } catch (IOException e) {
-            LOGGER.warning("Client seems dead. Closing communication"); //$NON-NLS-1$
-            LOGGER.log(Level.FINE, "Wait on message from client failed", e); //$NON-NLS-1$
-            return false;
-        }
-        if (!app.isRunning()) {
-            return false;
-        }
-        String ln = reading.getMessage();
-        if (ln.equals(close)) {
-            return false;
-        }
-        // Pass command to application
-        consoleManager.type(ln);
-        return true;
-    }
-
-    /** @return the consoleManager */
-    public synchronized ConsoleManager getConsoleManager() {
-        return consoleManager;
-    }
-
-    /** @param app the application to set */
-    public synchronized void setApplication(ConsoleApplication app) {
-        this.app = app;
-    }
-
     /** This method will request the server to stop.
      * <p>
      * In most cases, this will terminate communication on every client. On some
@@ -375,7 +394,7 @@ public class SocketConsoleApplicationShell implements Runnable, AutoCloseable {
         running = false;
         try {
             serverSocket.close();
-        } catch (IOException e) {
+        } catch (final IOException e) {
             LOGGER.log(Level.SEVERE, "Exception in closing socket server", e); //$NON-NLS-1$
         }
         app.exit();
@@ -387,17 +406,10 @@ public class SocketConsoleApplicationShell implements Runnable, AutoCloseable {
             synchronized (this) {
                 wait(ONE_TENTH_OF_SECOND);
             }
-        } catch (InterruptedException e) {
+        } catch (final InterruptedException e) {
             LOGGER.log(Level.SEVERE, "Interrupted wait", //$NON-NLS-1$
                     e);
             return;
         }
     }
-
-    /* (non-Javadoc)
-     * @see java.lang.AutoCloseable#close() */
-    @Override
-    public void close() throws IOException {
-        consoleManager.close();
-    }
 }

gclc-socket/src/test/java/fr/bigeon/gclc/socket/ConsoleRunnableTest.java

@@ -42,7 +42,7 @@ import java.io.IOException;
 
 import org.junit.Test;
 
-import fr.bigeon.gclc.manager.ConsoleManager;
+import fr.bigeon.gclc.manager.ConsoleInput;
 
 /** Test class for {@link ConsoleRunnable}
  *
@@ -55,71 +55,25 @@ public class ConsoleRunnableTest {
      *
      * @author Emmanuel Bigeon */
     private static final class ConsoleManagerTestImplementation
-            implements ConsoleManager {
+            implements ConsoleInput {
         int i = 0;
         String[] cmds;
 
         /** @param cmds the commands to run */
-        public ConsoleManagerTestImplementation(String[] cmds) {
+        public ConsoleManagerTestImplementation(final String[] cmds) {
             super();
             this.cmds = cmds;
         }
 
-        @Override
-        public void setPrompt(String prompt) {
-            // do nothing
-        }
-
-        @Override
-        public String getPrompt() {
-            // Not used in test
-            return ""; //$NON-NLS-1$
-        }
-
-        @Override
-        public String prompt() {
-            try {
-                Thread.sleep(1000);
-            } catch (InterruptedException e) { // NOSONAR
-                // do nothing
-            }
-            i++;
-            if (i == cmds.length) {
-                i = 0;
-            }
-            return cmds[i];
-        }
-
-        @Override
-        public String prompt(String message) {
-            return prompt();
-        }
-
-        @Override
-        public void println(String message) {
-            // do nothing
-        }
-
-        @Override
-        public void println() {
-            // do nothing
-        }
-
-        @Override
-        public void print(String text) {
-            // do nothing
-        }
-
         @Override
         public void close() throws IOException {
             // do nothing
         }
 
-        /* (non-Javadoc)
-         * @see fr.bigeon.gclc.manager.ConsoleManager#isClosed() */
         @Override
-        public boolean isClosed() {
-            return i == cmds.length;
+        public String getPrompt() {
+            // Not used in test
+            return ""; //$NON-NLS-1$
         }
 
         /* (non-Javadoc)
@@ -129,10 +83,36 @@ public class ConsoleRunnableTest {
             //
         }
 
+        /* (non-Javadoc)
+         * @see fr.bigeon.gclc.manager.ConsoleManager#isClosed() */
+        @Override
+        public boolean isClosed() {
+            return i == cmds.length;
+        }
+
+        @Override
+        public String prompt() {
+            try {
+                Thread.sleep(1000);
+            } catch (final InterruptedException e) { // NOSONAR
+                // do nothing
+            }
+            i++;
+            if (i == cmds.length) {
+                i = 0;
+            }
+            return cmds[i];
+        }
+
         /* (non-Javadoc)
          * @see fr.bigeon.gclc.manager.ConsoleManager#prompt(long) */
         @Override
-        public String prompt(long timeout) throws IOException {
+        public String prompt(final long timeout) throws IOException {
+            return prompt();
+        }
+
+        @Override
+        public String prompt(final String message) {
             return prompt();
         }
 
@@ -140,9 +120,14 @@ public class ConsoleRunnableTest {
          * @see fr.bigeon.gclc.manager.ConsoleManager#prompt(java.lang.String,
          * long) */
         @Override
-        public String prompt(String message, long timeout) throws IOException {
+        public String prompt(final String message, final long timeout) throws IOException {
             return prompt(message);
         }
+
+        @Override
+        public void setPrompt(final String prompt) {
+            // do nothing
+        }
     }
 
     /** Test method for
@@ -156,6 +141,16 @@ public class ConsoleRunnableTest {
 
     }
 
+    /** Test method for {@link fr.bigeon.gclc.socket.ConsoleRunnable#stop()}. */
+    @Test
+    public void testRun() {
+//        ConsoleApplication app = new ConsoleTestApplication(
+//                new ConsoleManagerTestImplementation(
+//                        new String[] {"test", ConsoleTestApplication.EXIT})); //$NON-NLS-1$
+//        ConsoleRunnable runnable = new ConsoleRunnable(app);
+//        runnable.run();
+    }
+
     /** Test method for {@link fr.bigeon.gclc.socket.ConsoleRunnable#run()}. */
     @Test
     public void testRunFlow() {
@@ -184,14 +179,4 @@ public class ConsoleRunnableTest {
 //        runnable.stop();
     }
 
-    /** Test method for {@link fr.bigeon.gclc.socket.ConsoleRunnable#stop()}. */
-    @Test
-    public void testRun() {
-//        ConsoleApplication app = new ConsoleTestApplication(
-//                new ConsoleManagerTestImplementation(
-//                        new String[] {"test", ConsoleTestApplication.EXIT})); //$NON-NLS-1$
-//        ConsoleRunnable runnable = new ConsoleRunnable(app);
-//        runnable.run();
-    }
-
 }

gclc-socket/src/test/java/fr/bigeon/gclc/socket/ConsoleTestApplication.java

@@ -42,10 +42,11 @@ import fr.bigeon.gclc.command.ExitCommand;
 import fr.bigeon.gclc.command.HelpExecutor;
 import fr.bigeon.gclc.exception.CommandRunException;
 import fr.bigeon.gclc.exception.InvalidCommandName;
-import fr.bigeon.gclc.manager.ConsoleManager;
+import fr.bigeon.gclc.manager.ConsoleInput;
+import fr.bigeon.gclc.manager.ConsoleOutput;
 
 /** A test-purpose application
- * 
+ *
  * @author Emmanuel Bigeon */
 public class ConsoleTestApplication {
 
@@ -55,40 +56,59 @@ public class ConsoleTestApplication {
     /** @param manager the manager
      * @return create the application */
     @SuppressWarnings("nls")
-    public static ConsoleApplication create(final ConsoleManager manager) {
+    public static ConsoleApplication create(final ConsoleOutput manager,
+                                            final ConsoleInput input) {
         try {
-            ConsoleApplication application = new ConsoleApplication(manager,
+            final ConsoleApplication application = new ConsoleApplication(
+                    manager, input,
                     "Welcome to the test application. Type help or test.",
                     "See you");
             application.add(new ExitCommand(EXIT, application));
-            application.add(
-                    new HelpExecutor("help", manager, application.root));
+            application
+                    .add(new HelpExecutor("help", application.root));
             application.add(new Command("test") {
 
+                /* (non-Javadoc)
+                 * @see fr.bigeon.gclc.command.ICommand#execute(fr.bigeon.gclc.
+                 * manager.ConsoleOutput, fr.bigeon.gclc.manager.ConsoleInput,
+                 * java.lang.String[]) */
+                @Override
+                public void execute(final ConsoleOutput out,
+                                    final ConsoleInput in,
+                                    final String... args) throws CommandRunException {
+                    try {
+                        manager.println("Test command ran fine");
+                    } catch (final IOException e) {
+                        throw new CommandRunException("manager closed", e,
+                                this);
+                    }
+                }
+
                 @Override
                 public String tip() {
                     return "A test command";
                 }
 
+                /* (non-Javadoc)
+                 * @see fr.bigeon.gclc.command.Command#usageDetail()
+                 */
                 @Override
-                public void execute(String... args) throws CommandRunException {
-                    try {
-                        manager.println("Test command ran fine");
-                    } catch (IOException e) {
-                        throw new CommandRunException("manager closed", e,
-                                this);
-                    }
+                protected String usageDetail() {
+                    // TODO Auto-generated method stub
+                    // return null;
+                    throw new RuntimeException("Not implemented yet");
                 }
             });
             application.add(new Command("long") {
 
+                /* (non-Javadoc)
+                 * @see fr.bigeon.gclc.command.ICommand#execute(fr.bigeon.gclc.
+                 * manager.ConsoleOutput, fr.bigeon.gclc.manager.ConsoleInput,
+                 * java.lang.String[]) */
                 @Override
-                public String tip() {
-                    return "A long run test command";
-                }
-
-                @Override
-                public void execute(String... args) throws CommandRunException {
+                public void execute(final ConsoleOutput out,
+                                    final ConsoleInput in,
+                                    final String... args) throws CommandRunException {
                     try {
                         Thread.sleep(2000);
                         manager.println("Test command ran fine");
@@ -97,6 +117,21 @@ public class ConsoleTestApplication {
                                 this);
                     }
                 }
+
+                @Override
+                public String tip() {
+                    return "A long run test command";
+                }
+
+                /* (non-Javadoc)
+                 * @see fr.bigeon.gclc.command.Command#usageDetail()
+                 */
+                @Override
+                protected String usageDetail() {
+                    // TODO Auto-generated method stub
+                    // return null;
+                    throw new RuntimeException("Not implemented yet");
+                }
             });
             return application;
         } catch (final InvalidCommandName e) {

gclc-socket/src/test/java/fr/bigeon/gclc/socket/TestServer.java

@@ -40,7 +40,7 @@ import java.nio.charset.Charset;
 import fr.bigeon.gclc.ConsoleApplication;
 
 /** A test server
- * 
+ *
  * @author Emmanuel Bigeon */
 @SuppressWarnings({"javadoc", "nls"})
 public class TestServer {
@@ -48,14 +48,9 @@ public class TestServer {
     private static SocketConsoleApplicationShell SHELL;
     private static Thread server;
 
-    /** @param args no argument
-     * @throws IOException if the server starting failed */
-    public static void main(String... args) throws IOException {
-        try {
-            startServer(false).join();
-        } catch (final InterruptedException e) {
-            e.printStackTrace();
-        }
+    public static void closeServer() {
+        SHELL.stop();
+        SHELL = null;
     }
 
     public static Thread getServer() throws IOException {
@@ -71,38 +66,43 @@ public class TestServer {
             SHELL = new SocketConsoleApplicationShell(3300, "close",
                     ConsoleTestApplication.EXIT, Charset.forName("UTF-8"));
             final ConsoleApplication app = ConsoleTestApplication
-                    .create(SHELL.getConsoleManager());
+                    .create(SHELL.getOutput(), SHELL.getInput());
             SHELL.setApplication(app);
         }
         return SHELL;
     }
 
-    public static Thread startServer(boolean autoClose) throws IOException {
+    /** @param args no argument
+     * @throws IOException if the server starting failed */
+    public static void main(final String... args) throws IOException {
+        try {
+            startServer(false).join();
+        } catch (final InterruptedException e) {
+            e.printStackTrace();
+        }
+    }
+
+    public static Thread startServer(final boolean autoClose) throws IOException {
         if (SHELL == null) {
             SHELL = new SocketConsoleApplicationShell(3300, autoClose,
                     ConsoleTestApplication.EXIT, Charset.forName("UTF-8"));
             final ConsoleApplication app = ConsoleTestApplication
-                    .create(SHELL.getConsoleManager());
+                    .create(SHELL.getOutput(), SHELL.getInput());
             SHELL.setApplication(app);
             server = null;
         }
         return getServer();
     }
 
-    public static Thread startServer(String closeConnection) throws IOException {
+    public static Thread startServer(final String closeConnection) throws IOException {
         if (SHELL == null) {
             SHELL = new SocketConsoleApplicationShell(3300, closeConnection,
                     ConsoleTestApplication.EXIT, Charset.forName("UTF-8"));
             final ConsoleApplication app = ConsoleTestApplication
-                    .create(SHELL.getConsoleManager());
+                    .create(SHELL.getOutput(), SHELL.getInput());
             SHELL.setApplication(app);
             server = null;
         }
         return getServer();
     }
-
-    public static void closeServer() {
-        SHELL.stop();
-        SHELL = null;
-    }
 }

gclc-swt/pom.xml

@@ -51,12 +51,12 @@
     <dependency>
       <groupId>fr.bigeon</groupId>
       <artifactId>gclc</artifactId>
-      <version>1.3.6</version>
+      <version>2.0.0</version>
     </dependency>
     <dependency>
       <groupId>fr.bigeon</groupId>
       <artifactId>collections</artifactId>
-      <version>1.0.1</version>
+      <version>1.1.0</version>
     </dependency>
   </dependencies>
   <inceptionYear>2015</inceptionYear>

gclc-swt/src/main/java/fr/bigeon/gclc/swt/SWTConsole.java

@@ -51,14 +51,15 @@ import org.eclipse.swt.widgets.Label;
 import org.eclipse.swt.widgets.Text;
 
 import fr.bigeon.gclc.ConsoleApplication;
-import fr.bigeon.gclc.manager.ConsoleManager;
+import fr.bigeon.gclc.manager.ConsoleInput;
+import fr.bigeon.gclc.manager.ConsoleOutput;
 
 /** A SWT component to connect to gclc {@link ConsoleApplication}
  * <p>
  *
  * @author Emmanuel Bigeon */
 public class SWTConsole extends Composite
-        implements ConsoleDelayIO, ConsoleManager {
+        implements ConsoleDelayIO, ConsoleInput, ConsoleOutput {
     /**
      *
      */
@@ -89,7 +90,7 @@ public class SWTConsole extends Composite
      *
      * @param parent the prent composite
      * @param style the composite style */
-    public SWTConsole(Composite parent, int style) {
+    public SWTConsole(final Composite parent, final int style) {
         super(parent, style);
 
         setLayout(new GridLayout(LAYOUT_NB_COLUMNS, false));
@@ -110,47 +111,32 @@ public class SWTConsole extends Composite
 
     }
 
-    /**
-     * 
-     */
-    @Override
-    public void validateInput() {
-        Display.getDefault().syncExec(new Runnable() {
-            @SuppressWarnings("synthetic-access")
-            @Override
-            public void run() {
-                consoleInput.setEnabled(false);
-            }
-        });
-        synchronized (promptLock) {
-            while (!prompting) {
-                try {
-                    promptLock.wait();
-                } catch (InterruptedException e) {
-                    LOGGER.log(Level.SEVERE,
-                            "Interruption while waiting prompt", e); //$NON-NLS-1$
-                }
-            }
-            Display.getDefault().syncExec(new Runnable() {
-                @SuppressWarnings("synthetic-access")
-                @Override
-                public void run() {
-                    command = consoleInput.getText();
-                    prompting = false;
-                    consoleInput.setText(EMPTY);
-                    consoleOutput.append(
-                            CMD_PREFIX + command + System.lineSeparator());
-                }
-            });
-            promptLock.notifyAll();
-        }
-    }
-
     @Override
     protected void checkSubclass() {
         // Disable the check that prevents subclassing of SWT components
     }
 
+    /* (non-Javadoc)
+     * @see fr.bigeon.gclc.manager.ConsoleManager#close() */
+    @Override
+    public void close() {
+        synchronized (promptLock) {
+            promptLock.notify();
+        }
+        if (consoleInput.isDisposed()) {
+            return;
+        }
+        consoleInput.setEnabled(false);
+        consoleOutput.setEnabled(false);
+    }
+
+    /* (non-Javadoc)
+     * @see fr.bigeon.gclc.swt.ConsoleDelayIO#getInput() */
+    @Override
+    public String getInput() {
+        return consoleInput.getText();
+    }
+
     /* (non-Javadoc)
      * @see fr.bigeon.gclc.ConsoleManager#getPrompt() */
     @Override
@@ -158,6 +144,22 @@ public class SWTConsole extends Composite
         return prompt;
     }
 
+    /* (non-Javadoc)
+     * @see fr.bigeon.gclc.manager.ConsoleManager#interruptPrompt() */
+    @Override
+    public void interruptPrompt() {
+        synchronized (promptLock) {
+            promptLock.notify();
+        }
+    }
+
+    /* (non-Javadoc)
+     * @see fr.bigeon.gclc.manager.ConsoleManager#isClosed() */
+    @Override
+    public boolean isClosed() {
+        return isDisposed();
+    }
+
     /* (non-Javadoc)
      * @see fr.bigeon.gclc.ConsoleManager#print(java.lang.String) */
     @Override
@@ -238,6 +240,16 @@ public class SWTConsole extends Composite
         return command;
     }
 
+    /* (non-Javadoc)
+     * @see fr.bigeon.gclc.manager.ConsoleInput#prompt(long)
+     */
+    @Override
+    public String prompt(final long timeout) throws IOException {
+        // TODO Auto-generated method stub
+        // return null;
+        throw new RuntimeException("Not implemented yet");
+    }
+
     /* (non-Javadoc)
      * @see fr.bigeon.gclc.ConsoleManager#prompt(java.lang.String) */
     @Override
@@ -286,6 +298,16 @@ public class SWTConsole extends Composite
         return command;
     }
 
+    /* (non-Javadoc)
+     * @see fr.bigeon.gclc.manager.ConsoleInput#prompt(java.lang.String, long)
+     */
+    @Override
+    public String prompt(final String message, final long timeout) throws IOException {
+        // TODO Auto-generated method stub
+        // return null;
+        throw new RuntimeException("Not implemented yet");
+    }
+
     /* (non-Javadoc)
      * @see org.eclipse.swt.widgets.Composite#setFocus() */
     @Override
@@ -293,6 +315,14 @@ public class SWTConsole extends Composite
         return consoleInput.setFocus();
     }
 
+    /* (non-Javadoc)
+     * @see fr.bigeon.gclc.swt.ConsoleDelayIO#setInput(java.lang.String) */
+    @Override
+    public void setInput(final String input) {
+        consoleInput.setText(input);
+        consoleInput.setSelection(input.length());
+    }
+
     /* (non-Javadoc)
      * @see fr.bigeon.gclc.ConsoleManager#setPrompt(java.lang.String) */
     @Override
@@ -311,60 +341,51 @@ public class SWTConsole extends Composite
         });
     }
 
-    /* (non-Javadoc)
-     * @see fr.bigeon.gclc.manager.ConsoleManager#close() */
-    @Override
-    public void close() {
-        synchronized (promptLock) {
-            promptLock.notify();
-        }
-        if (consoleInput.isDisposed()) {
-            return;
-        }
-        consoleInput.setEnabled(false);
-        consoleOutput.setEnabled(false);
-    }
-
-    /* (non-Javadoc)
-     * @see fr.bigeon.gclc.manager.ConsoleManager#isClosed() */
-    @Override
-    public boolean isClosed() {
-        return isDisposed();
-    }
-
     /** @param string the text */
-    public void setText(String string) {
+    public void setText(final String string) {
         consoleInput.setText(string);
     }
 
     /**
-     * 
+     *
      */
     public void validateCommand() {
         validateInput();
     }
 
-    /* (non-Javadoc)
-     * @see fr.bigeon.gclc.swt.ConsoleDelayIO#setInput(java.lang.String) */
+    /**
+     *
+     */
     @Override
-    public void setInput(String input) {
-        consoleInput.setText(input);
-        consoleInput.setSelection(input.length());
-    }
-
-    /* (non-Javadoc)
-     * @see fr.bigeon.gclc.swt.ConsoleDelayIO#getInput() */
-    @Override
-    public String getInput() {
-        return consoleInput.getText();
-    }
-
-    /* (non-Javadoc)
-     * @see fr.bigeon.gclc.manager.ConsoleManager#interruptPrompt() */
-    @Override
-    public void interruptPrompt() {
+    public void validateInput() {
+        Display.getDefault().syncExec(new Runnable() {
+            @SuppressWarnings("synthetic-access")
+            @Override
+            public void run() {
+                consoleInput.setEnabled(false);
+            }
+        });
         synchronized (promptLock) {
-            promptLock.notify();
+            while (!prompting) {
+                try {
+                    promptLock.wait();
+                } catch (final InterruptedException e) {
+                    LOGGER.log(Level.SEVERE,
+                            "Interruption while waiting prompt", e); //$NON-NLS-1$
+                }
+            }
+            Display.getDefault().syncExec(new Runnable() {
+                @SuppressWarnings("synthetic-access")
+                @Override
+                public void run() {
+                    command = consoleInput.getText();
+                    prompting = false;
+                    consoleInput.setText(EMPTY);
+                    consoleOutput.append(
+                            CMD_PREFIX + command + System.lineSeparator());
+                }
+            });
+            promptLock.notifyAll();
         }
     }
 

gclc-swt/src/main/java/fr/bigeon/gclc/swt/SWTConsoleShell.java

@@ -43,8 +43,6 @@ import org.eclipse.swt.layout.FillLayout;
 import org.eclipse.swt.widgets.Display;
 import org.eclipse.swt.widgets.Shell;
 
-import fr.bigeon.gclc.manager.ConsoleManager;
-
 /** A shell containing a {@link SWTConsole}
  * <p>
  *
@@ -57,7 +55,7 @@ public class SWTConsoleShell extends Shell {
     /** Create the shell.
      *
      * @param display the display */
-    public SWTConsoleShell(Display display) {
+    public SWTConsoleShell(final Display display) {
         super(display, SWT.SHELL_TRIM);
         setLayout(new FillLayout(SWT.HORIZONTAL));
 
@@ -75,11 +73,6 @@ public class SWTConsoleShell extends Shell {
         setText("Console Application"); //$NON-NLS-1$
     }
 
-    /** @return the console manager */
-    public ConsoleManager getManager() {
-        return console;
-    }
-
     /* (non-Javadoc)
      * @see org.eclipse.swt.widgets.Shell#dispose() */
     @Override
@@ -87,4 +80,9 @@ public class SWTConsoleShell extends Shell {
         super.dispose();
         console.close();
     }
+
+    /** @return the input and output. */
+    public SWTConsole getManager() {
+        return console;
+    }
 }

gclc-swt/src/main/java/fr/bigeon/gclc/swt/SWTConsoleView.java

@@ -50,7 +50,8 @@ import org.eclipse.swt.widgets.Display;
 import org.eclipse.swt.widgets.Text;
 
 import fr.bigeon.gclc.ConsoleApplication;
-import fr.bigeon.gclc.manager.PipedConsoleManager;
+import fr.bigeon.gclc.manager.PipedConsoleInput;
+import fr.bigeon.gclc.manager.PipedConsoleOutput;
 import fr.bigeon.gclc.tools.AOutputForwardRunnable;
 
 /** A SWT component to connect to gclc {@link ConsoleApplication}
@@ -59,7 +60,7 @@ import fr.bigeon.gclc.tools.AOutputForwardRunnable;
  * @author Emmanuel Bigeon */
 public class SWTConsoleView extends Composite implements ConsoleDelayIO {
     /** The local implementation of the forwarding runnable
-     * 
+     *
      * @author Emmanuel Bigeon */
     private final class ToSWTConsoleForwardRunnable
             extends AOutputForwardRunnable {
@@ -67,12 +68,12 @@ public class SWTConsoleView extends Composite implements ConsoleDelayIO {
         private boolean running = true;
 
         /** @param manager the manager */
-        public ToSWTConsoleForwardRunnable(PipedConsoleManager manager) {
+        public ToSWTConsoleForwardRunnable(final PipedConsoleOutput manager) {
             super(manager);
         }
 
         @Override
-        protected void forwardLine(String m) {
+        protected void forwardLine(final String m) {
             appendConsoleOutput(m);
         }
 
@@ -82,7 +83,7 @@ public class SWTConsoleView extends Composite implements ConsoleDelayIO {
         }
 
         /** @param running the running to set */
-        public void setRunning(boolean running) {
+        public void setRunning(final boolean running) {
             this.running = running;
         }
     }
@@ -95,7 +96,8 @@ public class SWTConsoleView extends Composite implements ConsoleDelayIO {
     /** The console input text field */
     private final Text consoleInput;
     /** The actual manager */
-    private PipedConsoleManager manager;
+    private PipedConsoleOutput manager;
+    private PipedConsoleInput input;
     /** The forwarding runnable */
     private ToSWTConsoleForwardRunnable forward;
 
@@ -103,7 +105,7 @@ public class SWTConsoleView extends Composite implements ConsoleDelayIO {
      *
      * @param parent the prent composite
      * @param style the composite style */
-    public SWTConsoleView(Composite parent, int style) {
+    public SWTConsoleView(final Composite parent, final int style) {
         super(parent, style);
 
         setLayout(new GridLayout(1, false));
@@ -120,17 +122,6 @@ public class SWTConsoleView extends Composite implements ConsoleDelayIO {
         consoleInput.addKeyListener(new HistoryTextKeyListener(this));
     }
 
-    /** @param manager the manager to set */
-    public void setManager(PipedConsoleManager manager) {
-        this.manager = manager;
-        if (forward != null) {
-            forward.setRunning(false);
-        }
-        forward = new ToSWTConsoleForwardRunnable(manager);
-        Thread th = new Thread(forward, "gclcToSWT"); //$NON-NLS-1$
-        th.start();
-    }
-
     /** @param next the next message */
     protected void appendConsoleOutput(final String next) {
         Display.getDefault().syncExec(new Runnable() {
@@ -142,23 +133,18 @@ public class SWTConsoleView extends Composite implements ConsoleDelayIO {
         });
     }
 
-    /**
-     * 
-     */
-    @Override
-    public void validateInput() {
-        try {
-            manager.type(getInput());
-        } catch (IOException e) {
-            LOGGER.log(Level.SEVERE, "Unable to input value to console", e); //$NON-NLS-1$
-        }
-    }
-
     @Override
     protected void checkSubclass() {
         // Disable the check that prevents subclassing of SWT components
     }
 
+    /* (non-Javadoc)
+     * @see fr.bigeon.gclc.swt.ConsoleDelayIO#getInput() */
+    @Override
+    public String getInput() {
+        return consoleInput.getText();
+    }
+
     /* (non-Javadoc)
      * @see org.eclipse.swt.widgets.Composite#setFocus() */
     @Override
@@ -166,23 +152,41 @@ public class SWTConsoleView extends Composite implements ConsoleDelayIO {
         return consoleInput.setFocus();
     }
 
-    /** @param string the text */
-    public void setText(String string) {
-        consoleInput.setText(string);
-    }
-
     /* (non-Javadoc)
      * @see fr.bigeon.gclc.swt.ConsoleDelayIO#setInput(java.lang.String) */
     @Override
-    public void setInput(String input) {
+    public void setInput(final String input) {
         consoleInput.setText(input);
         consoleInput.setSelection(input.length());
     }
 
-    /* (non-Javadoc)
-     * @see fr.bigeon.gclc.swt.ConsoleDelayIO#getInput() */
+    /** @param manager the manager to set */
+    public void setManager(final PipedConsoleOutput manager,
+                           final PipedConsoleInput input) {
+        this.manager = manager;
+        this.input = input;
+        if (forward != null) {
+            forward.setRunning(false);
+        }
+        forward = new ToSWTConsoleForwardRunnable(manager);
+        final Thread th = new Thread(forward, "gclcToSWT"); //$NON-NLS-1$
+        th.start();
+    }
+
+    /** @param string the text */
+    public void setText(final String string) {
+        consoleInput.setText(string);
+    }
+
+    /**
+     *
+     */
     @Override
-    public String getInput() {
-        return consoleInput.getText();
+    public void validateInput() {
+        try {
+            input.type(getInput());
+        } catch (final IOException e) {
+            LOGGER.log(Level.SEVERE, "Unable to input value to console", e); //$NON-NLS-1$
+        }
     }
 }

gclc-swt/src/test/java/fr/bigeon/gclc/swt/SWTConsoleShellTest.java

@@ -53,8 +53,11 @@ import fr.bigeon.gclc.command.Command;
 import fr.bigeon.gclc.command.ExitCommand;
 import fr.bigeon.gclc.exception.CommandRunException;
 import fr.bigeon.gclc.exception.InvalidCommandName;
+import fr.bigeon.gclc.manager.ConsoleInput;
+import fr.bigeon.gclc.manager.ConsoleOutput;
 
-/** <p>
+/**
+ * <p>
  * TODO
  *
  * @author Emmanuel Bigeon */
@@ -65,64 +68,192 @@ public class SWTConsoleShellTest {
     private static final Display DISPLAY = Display.getDefault();
 
     @Test
-    public void testConsoleClose() {
+    public void test() {
         final SWTConsoleShell shell = new SWTConsoleShell(DISPLAY);
-        final SWTConsole swtConsole = (SWTConsole) shell.getManager();
-        swtConsole.close();
-        swtConsole.setPrompt(":");
+        final SWTConsole swtConsole = shell.getManager();
         try {
             final ConsoleApplication appl = new ConsoleApplication(swtConsole,
-                    "Hello", "See you");
+                    swtConsole, "Hello", "See you");
             appl.add(new ExitCommand("exit", appl));
             appl.add(new Command("long") {
 
+                /* (non-Javadoc)
+                 * @see fr.bigeon.gclc.command.ICommand#execute(fr.bigeon.gclc.
+                 * manager.ConsoleOutput, fr.bigeon.gclc.manager.ConsoleInput,
+                 * java.lang.String[]) */
+                @Override
+                public void execute(final ConsoleOutput out,
+                                    final ConsoleInput in,
+                                    final String... args) throws CommandRunException {
+                    try {
+                        Thread.sleep(TWO_SECONDS);
+                    } catch (final InterruptedException e) {
+                        // TODO Auto-generated catch block
+                        e.printStackTrace();
+                    }
+                }
+
                 @Override
                 public String tip() {
                     return "a long running command";
                 }
 
+                /* (non-Javadoc)
+                 * @see fr.bigeon.gclc.command.Command#usageDetail() */
                 @Override
-                public void execute(String... args) {
-                    try {
-                        Thread.sleep(TWO_SECONDS);
-                    } catch (InterruptedException e) {
-                        // TODO Auto-generated catch block
-                        e.printStackTrace();
-                    }
-                }
-            });
-            appl.add(new Command("test") {
-
-                @Override
-                public String tip() {
-                    return "a prompting running command";
-                }
-
-                @Override
-                public void execute(String... args) throws CommandRunException {
-                    try {
-                        appl.getManager().prompt("Test");
-                    } catch (IOException e) {
-                        throw new CommandRunException("No input", e, this);
-                    }
+                protected String usageDetail() {
+                    // TODO Auto-generated method stub
+                    // return null;
+                    throw new RuntimeException("Not implemented yet");
                 }
             });
 //            shell.pack();
             shell.open();
-            Thread applThread = new Thread(new Runnable() {
+            final Thread applThread = new Thread(new Runnable() {
 
                 @Override
                 public void run() {
                     appl.start();
                 }
             });
-            Thread testThread = new Thread(new Runnable() {
+            final Thread testThread = new Thread(new Runnable() {
 
                 @Override
                 public void run() {
                     try {
                         Thread.sleep(TWO_SECONDS);
-                    } catch (InterruptedException e) {
+                    } catch (final InterruptedException e) {
+                        // TODO Auto-generated catch block
+                        e.printStackTrace();
+                    }
+                    Display.getDefault().syncExec(new Runnable() {
+                        @Override
+                        public void run() {
+                            swtConsole.setText("test"); //$NON-NLS-1$
+                            swtConsole.validateCommand();
+                        }
+                    });
+                    try {
+                        Thread.sleep(TWO_SECONDS);
+                    } catch (final InterruptedException e) {
+                        // TODO Auto-generated catch block
+                        e.printStackTrace();
+                    }
+                    Display.getDefault().syncExec(new Runnable() {
+                        @Override
+                        public void run() {
+                            shell.dispose();
+                        }
+                    });
+                }
+            });
+            applThread.start();
+            testThread.start();
+            while (!shell.isDisposed()) {
+                if (!DISPLAY.readAndDispatch()) {
+                    DISPLAY.sleep();
+                }
+            }
+//            DISPLAY.dispose();
+            assertTrue(swtConsole.isClosed());
+            Thread.sleep(TWO_SECONDS);
+            assertFalse(appl.isRunning());
+        } catch (final InvalidCommandName e) {
+            // TODO Auto-generated catch block
+            e.printStackTrace();
+        } catch (final InterruptedException e) {
+            // TODO Auto-generated catch block
+            e.printStackTrace();
+        }
+    }
+
+    @Test
+    public void testConsoleClose() {
+        final SWTConsoleShell shell = new SWTConsoleShell(DISPLAY);
+        final SWTConsole swtConsole = shell.getManager();
+        swtConsole.close();
+        swtConsole.setPrompt(":");
+        try {
+            final ConsoleApplication appl = new ConsoleApplication(swtConsole,
+                    swtConsole, "Hello", "See you");
+            appl.add(new ExitCommand("exit", appl));
+            appl.add(new Command("long") {
+                /* (non-Javadoc)
+                 * @see fr.bigeon.gclc.command.ICommand#execute(fr.bigeon.gclc.
+                 * manager.ConsoleOutput, fr.bigeon.gclc.manager.ConsoleInput,
+                 * java.lang.String[]) */
+                @Override
+                public void execute(final ConsoleOutput out,
+                                    final ConsoleInput in,
+                                    final String... args) throws CommandRunException {
+                    try {
+                        Thread.sleep(TWO_SECONDS);
+                    } catch (final InterruptedException e) {
+                        // TODO Auto-generated catch block
+                        e.printStackTrace();
+                    }
+                }
+
+                @Override
+                public String tip() {
+                    return "a long running command";
+                }
+
+                /* (non-Javadoc)
+                 * @see fr.bigeon.gclc.command.Command#usageDetail() */
+                @Override
+                protected String usageDetail() {
+                    // TODO Auto-generated method stub
+                    // return null;
+                    throw new RuntimeException("Not implemented yet");
+                }
+            });
+            appl.add(new Command("test") {
+                /* (non-Javadoc)
+                 * @see fr.bigeon.gclc.command.ICommand#execute(fr.bigeon.gclc.
+                 * manager.ConsoleOutput, fr.bigeon.gclc.manager.ConsoleInput,
+                 * java.lang.String[]) */
+                @Override
+                public void execute(final ConsoleOutput out,
+                                    final ConsoleInput in,
+                                    final String... args) throws CommandRunException {
+                    try {
+                        swtConsole.prompt("Test");
+                    } catch (final IOException e) {
+                        throw new CommandRunException("No input", e, this);
+                    }
+                }
+
+                @Override
+                public String tip() {
+                    return "a prompting running command";
+                }
+
+                /* (non-Javadoc)
+                 * @see fr.bigeon.gclc.command.Command#usageDetail() */
+                @Override
+                protected String usageDetail() {
+                    // TODO Auto-generated method stub
+                    // return null;
+                    throw new RuntimeException("Not implemented yet");
+                }
+            });
+//            shell.pack();
+            shell.open();
+            final Thread applThread = new Thread(new Runnable() {
+
+                @Override
+                public void run() {
+                    appl.start();
+                }
+            });
+            final Thread testThread = new Thread(new Runnable() {
+
+                @Override
+                public void run() {
+                    try {
+                        Thread.sleep(TWO_SECONDS);
+                    } catch (final InterruptedException e) {
                         // TODO Auto-generated catch block
                         e.printStackTrace();
                     }
@@ -163,7 +294,7 @@ public class SWTConsoleShellTest {
                     swtConsole.validateCommand();
                     try {
                         Thread.sleep(TWO_SECONDS);
-                    } catch (InterruptedException e) {
+                    } catch (final InterruptedException e) {
                         // TODO Auto-generated catch block
                         e.printStackTrace();
                     }
@@ -187,102 +318,17 @@ public class SWTConsoleShellTest {
             try {
                 swtConsole.prompt();
                 fail("Prompting when closed should fail!");
-            } catch (IOException e) {
+            } catch (final IOException e) {
                 assertNotNull(e);
             }
 //            DISPLAY.dispose();
-            assertTrue(appl.getManager().isClosed());
+            assertTrue(swtConsole.isClosed());
             Thread.sleep(TWO_SECONDS);
             assertFalse(appl.isRunning());
-        } catch (InvalidCommandName e) {
+        } catch (final InvalidCommandName e) {
             // TODO Auto-generated catch block
             e.printStackTrace();
-        } catch (InterruptedException e) {
-            // TODO Auto-generated catch block
-            e.printStackTrace();
-        }
-    }
-
-    @Test
-    public void test() {
-        final SWTConsoleShell shell = new SWTConsoleShell(DISPLAY);
-        final SWTConsole swtConsole = (SWTConsole) shell.getManager();
-        try {
-            final ConsoleApplication appl = new ConsoleApplication(swtConsole,
-                    "Hello", "See you");
-            appl.add(new ExitCommand("exit", appl));
-            appl.add(new Command("long") {
-
-                @Override
-                public String tip() {
-                    return "a long running command";
-                }
-
-                @Override
-                public void execute(String... args) {
-                    try {
-                        Thread.sleep(TWO_SECONDS);
-                    } catch (InterruptedException e) {
-                        // TODO Auto-generated catch block
-                        e.printStackTrace();
-                    }
-                }
-            });
-//            shell.pack();
-            shell.open();
-            Thread applThread = new Thread(new Runnable() {
-
-                @Override
-                public void run() {
-                    appl.start();
-                }
-            });
-            Thread testThread = new Thread(new Runnable() {
-
-                @Override
-                public void run() {
-                    try {
-                        Thread.sleep(TWO_SECONDS);
-                    } catch (InterruptedException e) {
-                        // TODO Auto-generated catch block
-                        e.printStackTrace();
-                    }
-                    Display.getDefault().syncExec(new Runnable() {
-                        @Override
-                        public void run() {
-                            swtConsole.setText("test"); //$NON-NLS-1$
-                            swtConsole.validateCommand();
-                        }
-                    });
-                    try {
-                        Thread.sleep(TWO_SECONDS);
-                    } catch (InterruptedException e) {
-                        // TODO Auto-generated catch block
-                        e.printStackTrace();
-                    }
-                    Display.getDefault().syncExec(new Runnable() {
-                        @Override
-                        public void run() {
-                            shell.dispose();
-                        }
-                    });
-                }
-            });
-            applThread.start();
-            testThread.start();
-            while (!shell.isDisposed()) {
-                if (!DISPLAY.readAndDispatch()) {
-                    DISPLAY.sleep();
-                }
-            }
-//            DISPLAY.dispose();
-            assertTrue(appl.getManager().isClosed());
-            Thread.sleep(TWO_SECONDS);
-            assertFalse(appl.isRunning());
-        } catch (InvalidCommandName e) {
-            // TODO Auto-generated catch block
-            e.printStackTrace();
-        } catch (InterruptedException e) {
+        } catch (final InterruptedException e) {
             // TODO Auto-generated catch block
             e.printStackTrace();
         }

gclc-swt/src/test/java/fr/bigeon/gclc/swt/SWTConsoleViewTest.java

@@ -50,8 +50,12 @@ import org.junit.Test;
 import fr.bigeon.gclc.ConsoleApplication;
 import fr.bigeon.gclc.command.Command;
 import fr.bigeon.gclc.command.ExitCommand;
+import fr.bigeon.gclc.exception.CommandRunException;
 import fr.bigeon.gclc.exception.InvalidCommandName;
-import fr.bigeon.gclc.manager.PipedConsoleManager;
+import fr.bigeon.gclc.manager.ConsoleInput;
+import fr.bigeon.gclc.manager.ConsoleOutput;
+import fr.bigeon.gclc.manager.PipedConsoleInput;
+import fr.bigeon.gclc.manager.PipedConsoleOutput;
 
 /** <p>
  * TODO
@@ -67,49 +71,65 @@ public class SWTConsoleViewTest {
     public void test() {
         final Shell shell = new Shell(DISPLAY);
         final SWTConsoleView swtConsole = new SWTConsoleView(shell, SWT.NONE);
-        try (PipedConsoleManager manager = new PipedConsoleManager()) {
-            swtConsole.setManager(manager);
-        } catch (IOException e2) {
+        try (PipedConsoleOutput manager = new PipedConsoleOutput();
+             PipedConsoleInput input = new PipedConsoleInput()) {
+            swtConsole.setManager(manager, input);
+        } catch (final IOException e2) {
             assertNull(e2);
         }
-        try (PipedConsoleManager manager = new PipedConsoleManager()) {
-            swtConsole.setManager(manager);
+        try (PipedConsoleOutput manager = new PipedConsoleOutput();
+             PipedConsoleInput input = new PipedConsoleInput()) {
+            swtConsole.setManager(manager, input);
             final ConsoleApplication appl = new ConsoleApplication(manager,
+                    input,
                     "Hello", "See you");
             appl.add(new ExitCommand("exit", appl));
             appl.add(new Command("long") {
 
+                /* (non-Javadoc)
+                 * @see fr.bigeon.gclc.command.ICommand#execute(fr.bigeon.gclc.manager.ConsoleOutput, fr.bigeon.gclc.manager.ConsoleInput, java.lang.String[])
+                 */
+                @Override
+                public void execute(final ConsoleOutput out, final ConsoleInput in,
+                                    final String... args) throws CommandRunException {
+                    try {
+                        Thread.sleep(TWO_SECONDS);
+                    } catch (final InterruptedException e) {
+                        // TODO Auto-generated catch block
+                        e.printStackTrace();
+                    }
+                }
+
                 @Override
                 public String tip() {
                     return "a long running command";
                 }
 
+                /* (non-Javadoc)
+                 * @see fr.bigeon.gclc.command.Command#usageDetail() */
                 @Override
-                public void execute(String... args) {
-                    try {
-                        Thread.sleep(TWO_SECONDS);
-                    } catch (InterruptedException e) {
-                        // TODO Auto-generated catch block
-                        e.printStackTrace();
-                    }
+                protected String usageDetail() {
+                    // TODO Auto-generated method stub
+                    // return null;
+                    throw new RuntimeException("Not implemented yet");
                 }
             });
 //            shell.pack();
             shell.open();
-            Thread applThread = new Thread(new Runnable() {
+            final Thread applThread = new Thread(new Runnable() {
 
                 @Override
                 public void run() {
                     appl.start();
                 }
             });
-            Thread testThread = new Thread(new Runnable() {
+            final Thread testThread = new Thread(new Runnable() {
 
                 @Override
                 public void run() {
                     try {
                         Thread.sleep(TWO_SECONDS);
-                    } catch (InterruptedException e) {
+                    } catch (final InterruptedException e) {
                         // TODO Auto-generated catch block
                         e.printStackTrace();
                     }
@@ -122,7 +142,7 @@ public class SWTConsoleViewTest {
                     });
                     try {
                         Thread.sleep(TWO_SECONDS);
-                    } catch (InterruptedException e) {
+                    } catch (final InterruptedException e) {
                         // TODO Auto-generated catch block
                         e.printStackTrace();
                     }
@@ -141,10 +161,10 @@ public class SWTConsoleViewTest {
                     DISPLAY.sleep();
                 }
             }
-        } catch (InvalidCommandName e) {
+        } catch (final InvalidCommandName e) {
             // TODO Auto-generated catch block
             e.printStackTrace();
-        } catch (IOException e1) {
+        } catch (final IOException e1) {
             // TODO Auto-generated catch block
             e1.printStackTrace();
         }

gclc.system/pom.xml

@@ -23,7 +23,7 @@
     <dependency>
       <groupId>fr.bigeon</groupId>
       <artifactId>gclc</artifactId>
-      <version>1.3.1</version>
+      <version>2.0.0</version>
     </dependency>
   </dependencies>
   <name>GCLC system command</name>

gclc.system/src/main/java/net/bigeon/gclc/system/ExecSystemCommand.java

@@ -15,7 +15,8 @@ import java.util.logging.Logger;
 import fr.bigeon.gclc.command.Command;
 import fr.bigeon.gclc.exception.CommandRunException;
 import fr.bigeon.gclc.exception.CommandRunExceptionType;
-import fr.bigeon.gclc.manager.ConsoleManager;
+import fr.bigeon.gclc.manager.ConsoleInput;
+import fr.bigeon.gclc.manager.ConsoleOutput;
 
 /** A command that will execute a system command.
  *
@@ -29,71 +30,68 @@ public class ExecSystemCommand extends Command {
     /** The class logger */
     private static final Logger LOGGER = Logger
             .getLogger(ExecSystemCommand.class.getName());
-    /** The manager for the application's user interface */
-    private final ConsoleManager manager;
 
-    /** @param name the name of the command (the input from the manager that
-     *            should trigger this command)
-     * @param manager the console manager for input and outputs */
-    public ExecSystemCommand(String name, ConsoleManager manager) {
-        super(name);
-        this.manager = manager;
+    /***/
+    public ExecSystemCommand() {
+        super(COMMAND_DEFAULT_NAME);
     }
 
-    /** @param manager the console manager for input and outputs */
-    public ExecSystemCommand(ConsoleManager manager) {
-        super(COMMAND_DEFAULT_NAME);
-        this.manager = manager;
+    /** @param name the name of the command (the input from the manager that
+     *            should trigger this command) */
+    public ExecSystemCommand(final String name) {
+        super(name);
     }
 
     /* (non-Javadoc)
-     * @see fr.bigeon.gclc.command.ICommand#execute(java.lang.String[]) */
-    @SuppressWarnings("resource")
+     * @see fr.bigeon.gclc.command.ICommand#execute(fr.bigeon.gclc.manager.
+     * ConsoleOutput, fr.bigeon.gclc.manager.ConsoleInput,
+     * java.lang.String[]) */
     @Override
-    public void execute(String... args) throws CommandRunException {
+    public void execute(final ConsoleOutput out, final ConsoleInput in,
+                        final String... args) throws CommandRunException {
         Process proc;
         try {
             proc = Runtime.getRuntime().exec(args);
-        } catch (IOException e2) {
+        } catch (final IOException e2) {
             LOGGER.log(Level.SEVERE, "Unable to run process", e2); //$NON-NLS-1$
             return;
         }
 
         final InputStream is = proc
                 .getInputStream();
-        Thread th = new Thread(new Runnable() {
+        final Thread th = new Thread(new Runnable() {
 
             @SuppressWarnings("synthetic-access")
             @Override
             public void run() {
                 try {
-                    readToEnd(is);
+                    readToEnd(out, is);
                     is.close();
-                } catch (CommandRunException e) {
+                } catch (final CommandRunException e) {
                     LOGGER.log(Level.WARNING,
                             "Manager was closed in the meantime...", e); //$NON-NLS-1$
-                } catch (IOException e) {
+                } catch (final IOException e) {
                     LOGGER.log(Level.WARNING, "Input stream was closed...", e); //$NON-NLS-1$
                 }
             }
         });
         th.start();
-        manager.setPrompt(""); //$NON-NLS-1$
+        in.setPrompt(""); //$NON-NLS-1$
         final OutputStream os = proc.getOutputStream();
         try (BufferedWriter writer = new BufferedWriter(
                 new OutputStreamWriter(os))) {
             while (th.isAlive()) {
                 String user;
                 try {
-                    user = manager.prompt();
-                } catch (IOException e) {
+                    user = in.prompt();
+                } catch (final IOException e) {
                     throw new CommandRunException(
                             CommandRunExceptionType.INTERACTION,
                             "manager was closed", e, this); //$NON-NLS-1$
                 }
                 writer.write(user + EOL);
             }
-        } catch (IOException e1) {
+        } catch (final IOException e1) {
             throw new CommandRunException(CommandRunExceptionType.INTERACTION,
                     "manager was closed", e1, this); //$NON-NLS-1$
         }
@@ -102,23 +100,31 @@ public class ExecSystemCommand extends Command {
     /** @param is the input stream
      * @throws CommandRunException if the manager was closed while writing the
      *             stream */
-    protected void readToEnd(InputStream is) throws CommandRunException {
+    protected void readToEnd(final ConsoleOutput out,
+                             final InputStream is) throws CommandRunException {
         int c;
         try {
             while ((c = is.read()) != -1) {
                 try {
-                    manager.print(Character.valueOf((char) c).toString());
-                } catch (IOException e) {
+                    out.print(Character.valueOf((char) c).toString());
+                } catch (final IOException e) {
                     throw new CommandRunException(
                             CommandRunExceptionType.INTERACTION,
                             "manager was closed", e, this); //$NON-NLS-1$
                 }
             }
-        } catch (IOException e) {
+        } catch (final IOException e) {
             LOGGER.log(Level.INFO, "input stream reading failed", e); //$NON-NLS-1$
         }
     }
 
+    /* (non-Javadoc)
+     * @see fr.bigeon.gclc.command.ICommand#tip() */
+    @Override
+    public String tip() {
+        return "Execute a system command"; //$NON-NLS-1$
+    }
+
     /* (non-Javadoc)
      * @see fr.bigeon.gclc.command.Command#usageDetail() */
     @Override
@@ -139,11 +145,4 @@ public class ExecSystemCommand extends Command {
         return "  CMD <system command>"; //$NON-NLS-1$
     }
 
-    /* (non-Javadoc)
-     * @see fr.bigeon.gclc.command.ICommand#tip() */
-    @Override
-    public String tip() {
-        return "Execute a system command"; //$NON-NLS-1$
-    }
-
 }

gclc/pom.xml

@@ -35,7 +35,7 @@
 <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
 	<modelVersion>4.0.0</modelVersion>
 	<artifactId>gclc</artifactId>
-	<version>2.0.0</version>
+	<version>2.0.1</version>
 	<packaging>jar</packaging>
 	<url>http://www.bigeon.fr/emmanuel</url>
 	<properties>
@@ -83,6 +83,6 @@
   <scm>
   
     <developerConnection>scm:git:gogs@git.code.bigeon.net:emmanuel/gclc.git</developerConnection>
-	<tag>gclc-2.0.0</tag>
+	<tag>gclc-2.0.1</tag>
   </scm>
 </project>

gclc/src/main/java/fr/bigeon/gclc/manager/PipedConsoleInput.java

@@ -38,9 +38,7 @@
  */
 package fr.bigeon.gclc.manager;
 
-import java.io.BufferedReader;
 import java.io.IOException;
-import java.io.InputStreamReader;
 import java.io.PipedInputStream;
 import java.io.PipedOutputStream;
 import java.io.PrintStream;
@@ -56,67 +54,35 @@ import java.nio.charset.StandardCharsets;
 public final class PipedConsoleInput
         implements ConsoleInput {
 
-    /** The encoding between streams. */
-    private static final String UTF_8 = "UTF-8"; //$NON-NLS-1$
     /** THe inner manager. */
     private final StreamConsoleInput innerManager;
     /** The stream to pipe commands into. */
     private final PipedOutputStream commandInput;
-    /** The reader to get application return from. */
-    private final BufferedReader commandBuffOutput;
-    /** The stream to get application return from. */
-    private final PipedInputStream commandOutput;
-    /** The print writer for application to write return to. */
-    private final PrintStream outPrint;
     /** The stream for the application to read commands from. */
     private final PipedInputStream in;
     /** The writing thread. */
     private final WritingRunnable writing;
-    /** The reading thread. */
-    private final ReadingRunnable reading;
 
     /** Create a manager that will write and read through piped stream.
      *
+     * @param outPrint the stream to write the prompting messages to
      * @throws IOException if the piping failed for streams */
-    public PipedConsoleInput() throws IOException {
+    public PipedConsoleInput(final PrintStream outPrint) throws IOException {
         commandInput = new PipedOutputStream();
         in = new PipedInputStream(commandInput);
-        commandOutput = new PipedInputStream();
-        final PipedOutputStream out = new PipedOutputStream(commandOutput);
-        commandBuffOutput = new BufferedReader(
-                new InputStreamReader(commandOutput, StandardCharsets.UTF_8));
-        outPrint = new PrintStream(out, true, UTF_8);
         innerManager = new StreamConsoleInput(outPrint, in,
                 StandardCharsets.UTF_8);
         writing = new WritingRunnable(commandInput, StandardCharsets.UTF_8);
-        reading = new ReadingRunnable(commandBuffOutput);
-        Thread th = new Thread(writing, "write"); //$NON-NLS-1$
+        final Thread th = new Thread(writing,
+                "GCLC console piped input stream"); //$NON-NLS-1$
         th.start();
-        th = new Thread(reading, "read"); //$NON-NLS-1$
-        th.setDaemon(true);
-        th.start();
-    }
-
-    /** Test if a content is available on the reading head.
-     * <p>
-     * If this method returns true, the next {@link #prompt()} operation should
-     * return immediatly.
-     *
-     * @return the content of the next line written by the application
-     * @throws IOException if the reading failed */
-    public boolean available() throws IOException {
-        return reading.hasMessage();
     }
 
     @Override
     public void close() throws IOException {
-        reading.setRunning(false);
         writing.setRunning(false);
         in.close();
         innerManager.close();
-        outPrint.close();
-        commandBuffOutput.close();
-        commandOutput.close();
         commandInput.close();
     }
 
@@ -125,18 +91,6 @@ public final class PipedConsoleInput
         return innerManager.getPrompt();
     }
 
-    /** Wait for a specific message to arrive.
-     * <p>
-     * When this method returns, the message was appended to the data, it
-     * <em>may or may not</em> be the next line of data.
-     *
-     * @param message the message
-     * @return the thread to join to wait for message delivery
-     * @see fr.bigeon.gclc.manager.ReadingRunnable#getWaitForDelivery(java.lang.String) */
-    public Thread getWaitForDelivery(final String message) {
-        return reading.getWaitForDelivery(message);
-    }
-
     /* (non-Javadoc)
      * @see fr.bigeon.gclc.manager.ConsoleManager#interruptPrompt() */
     @Override
@@ -181,16 +135,6 @@ public final class PipedConsoleInput
         return innerManager.prompt(message + System.lineSeparator(), timeout);
     }
 
-    /** Read the next line in the input printed content.
-     * <p>
-     * This corresponds to the {@link #prompt(String)} messages.
-     *
-     * @return the content of the next line written by the application
-     * @throws IOException if the reading failed */
-    public String readNextLine() throws IOException {
-        return reading.getMessage();
-    }
-
     /* (non-Javadoc)
      * @see fr.bigeon.gclc.manager.ConsoleInput#setPrompt(java.lang.String) */
     @Override

gclc/src/main/java/fr/bigeon/gclc/manager/PipedConsoleOutput.java

@@ -79,7 +79,7 @@ public final class PipedConsoleOutput
         outPrint = new PrintStream(out, true, UTF_8);
         innerManager = new StreamConsoleOutput(outPrint);
         reading = new ReadingRunnable(commandBuffOutput);
-        final Thread th = new Thread(reading, "read"); //$NON-NLS-1$
+        final Thread th = new Thread(reading, "GCLC console output forward"); //$NON-NLS-1$
         th.setDaemon(true);
         th.start();
     }

gclc/src/main/java/fr/bigeon/gclc/manager/StreamConsoleInput.java

@@ -154,7 +154,10 @@ public final class StreamConsoleInput implements ConsoleInput {
     @Override
     public String prompt(final String message) throws IOException {
         checkOpen();
-        out.print(message);
+        if (out != null) {
+            out.print(message);
+            out.flush();
+        }
         return reading.getMessage();
     }
 
@@ -164,7 +167,10 @@ public final class StreamConsoleInput implements ConsoleInput {
     public String prompt(final String message,
                          final long timeout) throws IOException {
         checkOpen();
-        out.print(message);
+        if (out != null) {
+            out.print(message);
+            out.flush();
+        }
         return reading.getNextMessage(timeout);
     }
 

gclc/src/test/java/fr/bigeon/gclc/CommandTestingApplication.java

@@ -63,7 +63,7 @@ public class CommandTestingApplication implements AutoCloseable {
     /** @throws IOException if the streams cannot be build */
     public CommandTestingApplication() throws IOException {
         out = new PipedConsoleOutput();
-        in = new PipedConsoleInput();
+        in = new PipedConsoleInput(null);
         application = new ConsoleApplication(out, in, "", "");
         new ConsoleTestApplication().attach(application);
         th = new Thread(new Runnable() {

gclc/src/test/java/fr/bigeon/gclc/ConsoleApplicationTest.java

@@ -44,7 +44,13 @@ import static org.junit.Assert.assertNotNull;
 import static org.junit.Assert.assertTrue;
 import static org.junit.Assert.fail;
 
+import java.io.BufferedReader;
 import java.io.IOException;
+import java.io.InputStreamReader;
+import java.io.PipedInputStream;
+import java.io.PipedOutputStream;
+import java.io.PrintStream;
+import java.nio.charset.StandardCharsets;
 
 import org.junit.Test;
 
@@ -72,8 +78,13 @@ public class ConsoleApplicationTest {
     @Test
     public void testConsoleApplication() {
 
-        try (PipedConsoleInput manager = new PipedConsoleInput()) {
-            final ConsoleApplication app = new ConsoleApplication(null, manager,
+        try (PipedOutputStream pout = new PipedOutputStream();
+             PipedInputStream pis = new PipedInputStream(pout);
+             BufferedReader buf = new BufferedReader(
+                     new InputStreamReader(pis, StandardCharsets.UTF_8));
+             PipedConsoleInput in = new PipedConsoleInput(
+                     new PrintStream(pout))) {
+            final ConsoleApplication app = new ConsoleApplication(null, in,
                     "", "");
             app.exit();
         } catch (final IOException e) {
@@ -146,7 +157,12 @@ public class ConsoleApplicationTest {
 
         ConsoleApplication appli = null;
         try (PipedConsoleOutput manager = new PipedConsoleOutput();
-             PipedConsoleInput in = new PipedConsoleInput()) {
+             PipedOutputStream pout = new PipedOutputStream();
+             PipedInputStream pis = new PipedInputStream(pout);
+             BufferedReader buf = new BufferedReader(
+                     new InputStreamReader(pis, StandardCharsets.UTF_8));
+             PipedConsoleInput in = new PipedConsoleInput(
+                     new PrintStream(pout))) {
             final ConsoleApplication app = new ConsoleApplication(manager, in,
                     null, null);
             appli = app;
@@ -176,7 +192,7 @@ public class ConsoleApplicationTest {
 
     @Test
     public void testInterpretCommand() throws InvalidCommandName, IOException {
-        try (PipedConsoleInput test = new PipedConsoleInput();
+        try (PipedConsoleInput test = new PipedConsoleInput(null);
              PipedConsoleOutput out = new PipedConsoleOutput()) {
             final ConsoleApplication appl = new ConsoleApplication(out, test,
                     "", "");

gclc/src/test/java/fr/bigeon/gclc/command/ParametrizedCommandTest.java

@@ -44,7 +44,13 @@ import static org.junit.Assert.assertNull;
 import static org.junit.Assert.assertTrue;
 import static org.junit.Assert.fail;
 
+import java.io.BufferedReader;
 import java.io.IOException;
+import java.io.InputStreamReader;
+import java.io.PipedInputStream;
+import java.io.PipedOutputStream;
+import java.io.PrintStream;
+import java.nio.charset.StandardCharsets;
 
 import org.junit.Test;
 
@@ -424,59 +430,79 @@ public class ParametrizedCommandTest {
             // ok
         }
         // TODO Test of interactive not providing and providing all needed
+    }
+
+    @Test
+    public void testExecuteInteractive() throws IOException,
+                                         CommandRunException,
+                                         InterruptedException {
+        ParametrizedCommand cmd;
+        final String addParam = "additional";
+        final String str1 = "str1";
+        final String str2 = "str2";
+        final String bool1 = "bool1";
+        final String bool2 = "bool2";
+
+        cmd = new ParametrizedCommand("name", false) {
+            {
+                try {
+                    addStringParameter(str1, true);
+                    addStringParameter(str2, false);
+                    addBooleanParameter(bool1);
+                    addBooleanParameter(bool2);
+                } catch (final InvalidParameterException e) {
+                    // TODO Auto-generated catch block
+                    e.printStackTrace();
+                }
+            }
+
+            @Override
+            protected void doExecute(final ConsoleOutput out,
+                                     final ConsoleInput in,
+                                     final CommandParameters parameters) throws CommandRunException {
+                if (!str2.equals(parameters.get(str1))) {
+                    throw new CommandRunException("Expected other argument",
+                            this);
+                }
+            }
+
+            @Override
+            public String tip() {
+                return "";
+            }
+
+            @Override
+            protected String usageDetail() {
+                return null;
+            }
+        };
         try (PipedConsoleOutput out = new PipedConsoleOutput();
-             PipedConsoleInput in = new PipedConsoleInput()) {
-            cmd = new ParametrizedCommand("name", false) {
-                {
-                    try {
-                        addStringParameter(str1, true);
-                        addStringParameter(str2, false);
-                        addBooleanParameter(bool1);
-                        addBooleanParameter(bool2);
-                    } catch (final InvalidParameterException e) {
-                        // TODO Auto-generated catch block
-                        e.printStackTrace();
-                    }
-                }
-
-                @Override
-                protected void doExecute(final ConsoleOutput out,
-                                         final ConsoleInput in,
-                                         final CommandParameters parameters) {
-                    assertEquals(str2, parameters.get(str1));
-                }
-
-                @Override
-                public String tip() {
-                    return "";
-                }
-
-                @Override
-                protected String usageDetail() {
-                    return null;
-                }
-            };
+             PipedOutputStream pout = new PipedOutputStream();
+             PipedInputStream pis = new PipedInputStream(pout);
+             BufferedReader buf = new BufferedReader(
+                     new InputStreamReader(pis, StandardCharsets.UTF_8));
+             PipedConsoleInput in = new PipedConsoleInput(
+                     new PrintStream(pout))) {
             cmd.execute(out, in, "-" + str1, str2);
             cmd.execute(out, in, "-" + str1, str2, "-" + bool1);
             cmd.execute(out, in, "-" + str1, str2, addParam);
             cmd.execute(out, in, "-" + str1, str2, "-" + addParam);
             cmd.execute(out, in, "-" + str1, str2, "-" + addParam, addParam);
 
-            Thread th = new Thread(new Runnable() {
+            final Thread th = new Thread(new Runnable() {
 
                 @Override
                 public void run() {
                     try {
-                        assertEquals("value of " + str1 + "? ",
-                                in.readNextLine());
+                        assertEquals("value of " + str1 + "? ", buf.readLine());
                         in.type("");
                         assertEquals(
                                 "value of " + str1 + "? (cannot be empty) ",
-                                in.readNextLine());
+                                buf.readLine());
                         in.type("");
                         assertEquals(
                                 "value of " + str1 + "? (cannot be empty) ",
-                                in.readNextLine());
+                                buf.readLine());
                         in.type(str2);
                     } catch (final IOException e) {
                         assertNull(e);
@@ -488,14 +514,21 @@ public class ParametrizedCommandTest {
             cmd.execute(out, in);
 
             th.join();
+        }
+        try (PipedConsoleOutput out = new PipedConsoleOutput();
+             PipedOutputStream pout = new PipedOutputStream();
+             PipedInputStream pis = new PipedInputStream(pout);
+             BufferedReader buf = new BufferedReader(
+                     new InputStreamReader(pis, StandardCharsets.UTF_8));
+             PipedConsoleInput in = new PipedConsoleInput(
+                     new PrintStream(pout))) {
 
-            th = new Thread(new Runnable() {
+            final Thread th = new Thread(new Runnable() {
 
                 @Override
                 public void run() {
                     try {
-                        assertEquals("value of " + str1 + "? ",
-                                in.readNextLine());
+                        assertEquals("value of " + str1 + "? ", buf.readLine());
                         in.type(str2);
                     } catch (final IOException e) {
                         assertNull(e);
@@ -510,37 +543,7 @@ public class ParametrizedCommandTest {
         }
         try {
             final PipedConsoleOutput out = new PipedConsoleOutput();
-            final PipedConsoleInput test = new PipedConsoleInput();
-            cmd = new ParametrizedCommand("name") {
-                {
-                    try {
-                        addStringParameter(str1, true);
-                        addStringParameter(str2, false);
-                        addBooleanParameter(bool1);
-                        addBooleanParameter(bool2);
-                    } catch (final InvalidParameterException e) {
-                        // TODO Auto-generated catch block
-                        e.printStackTrace();
-                    }
-                }
-
-                @Override
-                protected void doExecute(final ConsoleOutput out,
-                                         final ConsoleInput in,
-                                         final CommandParameters parameters) {
-                    assertEquals(str2, parameters.get(str1));
-                }
-
-                @Override
-                public String tip() {
-                    return "";
-                }
-
-                @Override
-                protected String usageDetail() {
-                    return null;
-                }
-            };
+            final PipedConsoleInput test = new PipedConsoleInput(null);
             test.close();
             out.close();
             cmd.execute(out, test, "-" + str1, str2);
@@ -549,7 +552,6 @@ public class ParametrizedCommandTest {
         } catch (final CommandRunException e) {
             // ok
         }
-
     }
 
     /** Test method for

gclc/src/test/java/fr/bigeon/gclc/command/ScriptExecutionTest.java

@@ -69,7 +69,7 @@ public class ScriptExecutionTest {
         PipedConsoleOutput test;
         PipedConsoleInput in;
         try {
-            in = new PipedConsoleInput();
+            in = new PipedConsoleInput(null);
             test = new PipedConsoleOutput();
         } catch (final IOException e2) {
             fail("creation of console manager failed"); //$NON-NLS-1$

gclc/src/test/java/fr/bigeon/gclc/prompt/CLIPrompterTest.java

@@ -43,7 +43,13 @@ import static org.junit.Assert.assertFalse;
 import static org.junit.Assert.assertTrue;
 import static org.junit.Assert.fail;
 
+import java.io.BufferedReader;
 import java.io.IOException;
+import java.io.InputStreamReader;
+import java.io.PipedInputStream;
+import java.io.PipedOutputStream;
+import java.io.PrintStream;
+import java.nio.charset.StandardCharsets;
 import java.util.ArrayList;
 import java.util.HashMap;
 import java.util.List;
@@ -80,7 +86,12 @@ public class CLIPrompterTest {
     @Test
     public final void testPromptBoolean() {
         try (final PipedConsoleOutput out = new PipedConsoleOutput();
-             PipedConsoleInput in = new PipedConsoleInput()) {
+             PipedOutputStream pout = new PipedOutputStream();
+             PipedInputStream pis = new PipedInputStream(pout);
+             BufferedReader buf = new BufferedReader(
+                     new InputStreamReader(pis, StandardCharsets.UTF_8));
+             PipedConsoleInput in = new PipedConsoleInput(
+                     new PrintStream(pout))) {
             final Thread th = new Thread(new Runnable() {
 
                 @Override
@@ -101,16 +112,16 @@ public class CLIPrompterTest {
                 }
             });
             th.start();
-            assertTrue(in.readNextLine().startsWith("My message")); //$NON-NLS-1$
+            assertTrue(buf.readLine().startsWith("My message")); //$NON-NLS-1$
             in.type(""); //$NON-NLS-1$
             out.readNextLine();
-            assertTrue(in.readNextLine().startsWith("My message")); //$NON-NLS-1$
+            assertTrue(buf.readLine().startsWith("My message")); //$NON-NLS-1$
             in.type("Y"); //$NON-NLS-1$
-            assertTrue(in.readNextLine().startsWith("My message")); //$NON-NLS-1$
+            assertTrue(buf.readLine().startsWith("My message")); //$NON-NLS-1$
             in.type("yes"); //$NON-NLS-1$
-            assertTrue(in.readNextLine().startsWith("My message")); //$NON-NLS-1$
+            assertTrue(buf.readLine().startsWith("My message")); //$NON-NLS-1$
             in.type("N"); //$NON-NLS-1$
-            assertTrue(in.readNextLine().startsWith("My message")); //$NON-NLS-1$
+            assertTrue(buf.readLine().startsWith("My message")); //$NON-NLS-1$
             in.type("nO"); //$NON-NLS-1$
             th.join();
         } catch (IOException | InterruptedException e) {
@@ -125,7 +136,12 @@ public class CLIPrompterTest {
     @Test
     public final void testPromptChoiceConsoleManagerListOfStringListOfUStringString() {
         try (final PipedConsoleOutput out = new PipedConsoleOutput();
-             PipedConsoleInput in = new PipedConsoleInput()) {
+             PipedOutputStream pout = new PipedOutputStream();
+             PipedInputStream pis = new PipedInputStream(pout);
+             BufferedReader buf = new BufferedReader(
+                     new InputStreamReader(pis, StandardCharsets.UTF_8));
+             PipedConsoleInput in = new PipedConsoleInput(
+                     new PrintStream(pout))) {
             final List<String> keys = new ArrayList<>();
             final List<Object> choices = new ArrayList<>();
             keys.add("A choice"); //$NON-NLS-1$
@@ -140,12 +156,15 @@ public class CLIPrompterTest {
                 @Override
                 public void run() {
                     try {
-                        assertEquals(choices.get(0), CLIPrompter.promptChoice(
-                                out, in, keys, choices, message, cancel));
-                        assertEquals(choices.get(0), CLIPrompter.promptChoice(
-                                out, in, keys, choices, message, null));
-                        assertEquals(null, CLIPrompter.promptChoice(out, in,
-                                keys, choices, message, cancel));
+                        assertEquals("Asserted provided value to be retrieved",
+                                choices.get(0), CLIPrompter.promptChoice(out,
+                                        in, keys, choices, message, cancel));
+                        assertEquals("Asserted provided value to be retrieved",
+                                choices.get(0), CLIPrompter.promptChoice(out,
+                                        in, keys, choices, message, null));
+                        assertEquals("Asserted provided value to be retrieved",
+                                null, CLIPrompter.promptChoice(out, in, keys,
+                                        choices, message, cancel));
                     } catch (final IOException e) {
                         fail("Unexpected io excpetion"); //$NON-NLS-1$
                         e.printStackTrace();
@@ -158,7 +177,7 @@ public class CLIPrompterTest {
             assertTrue(out.readNextLine().contains(keys.get(1)));
             assertTrue(out.readNextLine().contains(cancel));
             assertEquals(CLIPrompterMessages.getString("prompt.lineprompt"), //$NON-NLS-1$
-                    in.readNextLine());
+                    buf.readLine());
             in.type("yoyo"); //$NON-NLS-1$
             // fail, reprompt
             final String msg = CLIPrompterMessages.getString(
@@ -171,14 +190,14 @@ public class CLIPrompterTest {
             assertTrue(out.readNextLine().contains(keys.get(1)));
             assertTrue(out.readNextLine().contains(cancel));
             assertEquals(CLIPrompterMessages.getString("prompt.lineprompt"), //$NON-NLS-1$
-                    in.readNextLine());
+                    buf.readLine());
             in.type("0"); //$NON-NLS-1$
             // Sucess, reprompt without cancel
             assertTrue(out.readNextLine().startsWith(message));
             assertTrue(out.readNextLine().contains(keys.get(0)));
             assertTrue(out.readNextLine().contains(keys.get(1)));
             assertEquals(CLIPrompterMessages.getString("prompt.lineprompt"), //$NON-NLS-1$
-                    in.readNextLine());
+                    buf.readLine());
             in.type("2"); //$NON-NLS-1$
             // fail, reprompt
             assertEquals(
@@ -188,7 +207,7 @@ public class CLIPrompterTest {
             assertTrue(out.readNextLine().contains(keys.get(0)));
             assertTrue(out.readNextLine().contains(keys.get(1)));
             assertEquals(CLIPrompterMessages.getString("prompt.lineprompt"), //$NON-NLS-1$
-                    in.readNextLine());
+                    buf.readLine());
             in.type("0"); //$NON-NLS-1$
             // Sucess, prompt with cancel
             assertTrue(out.readNextLine().startsWith(message));
@@ -196,7 +215,7 @@ public class CLIPrompterTest {
             assertTrue(out.readNextLine().contains(keys.get(1)));
             assertTrue(out.readNextLine().contains(cancel));
             assertEquals(CLIPrompterMessages.getString("prompt.lineprompt"), //$NON-NLS-1$
-                    in.readNextLine());
+                    buf.readLine());
             in.type("2"); //$NON-NLS-1$
             th.join();
         } catch (IOException | InterruptedException e) {
@@ -208,7 +227,12 @@ public class CLIPrompterTest {
     @Test
     public final void testPromptChoiceConsoleManagerListOfUMapOfUTStringString() {
         try (final PipedConsoleOutput out = new PipedConsoleOutput();
-             PipedConsoleInput in = new PipedConsoleInput()) {
+             PipedOutputStream pout = new PipedOutputStream();
+             PipedInputStream pis = new PipedInputStream(pout);
+             BufferedReader buf = new BufferedReader(
+                     new InputStreamReader(pis, StandardCharsets.UTF_8));
+             PipedConsoleInput in = new PipedConsoleInput(
+                     new PrintStream(pout))) {
             final List<Object> keys = new ArrayList<>();
             final Map<Object, Object> choices = new HashMap<>();
             keys.add("A choice"); //$NON-NLS-1$
@@ -223,14 +247,17 @@ public class CLIPrompterTest {
                 @Override
                 public void run() {
                     try {
-                        assertEquals(choices.get(keys.get(0)),
-                                CLIPrompter.promptChoice(out, in, keys,
+                        assertEquals("Asserted provided value to be retrieved",
+                                choices.get(keys.get(0)),
+                                CLIPrompter.promptChoice(out, in, keys, choices,
+                                        message, cancel));
+                        assertEquals("Asserted provided value to be retrieved",
+                                choices.get(keys.get(0)),
+                                CLIPrompter.promptChoice(out, in, keys, choices,
+                                        message, null));
+                        assertEquals("Asserted provided value to be retrieved",
+                                null, CLIPrompter.promptChoice(out, in, keys,
                                         choices, message, cancel));
-                        assertEquals(choices.get(keys.get(0)),
-                                CLIPrompter.promptChoice(out, in, keys,
-                                        choices, message, null));
-                        assertEquals(null, CLIPrompter.promptChoice(out, in,
-                                keys, choices, message, cancel));
                     } catch (final IOException e) {
                         fail("Unexpected io excpetion"); //$NON-NLS-1$
                         e.printStackTrace();
@@ -243,7 +270,7 @@ public class CLIPrompterTest {
             assertTrue(out.readNextLine().contains(keys.get(1).toString()));
             assertTrue(out.readNextLine().contains(cancel));
             assertEquals(CLIPrompterMessages.getString("prompt.lineprompt"), //$NON-NLS-1$
-                    in.readNextLine());
+                    buf.readLine());
             in.type("yoyo"); //$NON-NLS-1$
             // fail, reprompt
             final String msg = CLIPrompterMessages.getString(
@@ -256,14 +283,14 @@ public class CLIPrompterTest {
             assertTrue(out.readNextLine().contains(keys.get(1).toString()));
             assertTrue(out.readNextLine().contains(cancel));
             assertEquals(CLIPrompterMessages.getString("prompt.lineprompt"), //$NON-NLS-1$
-                    in.readNextLine());
+                    buf.readLine());
             in.type("0"); //$NON-NLS-1$
             // Sucess, reprompt without cancel
             assertTrue(out.readNextLine().startsWith(message));
             assertTrue(out.readNextLine().contains(keys.get(0).toString()));
             assertTrue(out.readNextLine().contains(keys.get(1).toString()));
             assertEquals(CLIPrompterMessages.getString("prompt.lineprompt"), //$NON-NLS-1$
-                    in.readNextLine());
+                    buf.readLine());
             in.type("2"); //$NON-NLS-1$
             // fail, reprompt
             assertEquals(
@@ -273,7 +300,7 @@ public class CLIPrompterTest {
             assertTrue(out.readNextLine().contains(keys.get(0).toString()));
             assertTrue(out.readNextLine().contains(keys.get(1).toString()));
             assertEquals(CLIPrompterMessages.getString("prompt.lineprompt"), //$NON-NLS-1$
-                    in.readNextLine());
+                    buf.readLine());
             in.type("0"); //$NON-NLS-1$
             // Sucess, prompt with cancel
             assertTrue(out.readNextLine().startsWith(message));
@@ -281,7 +308,7 @@ public class CLIPrompterTest {
             assertTrue(out.readNextLine().contains(keys.get(1).toString()));
             assertTrue(out.readNextLine().contains(cancel));
             assertEquals(CLIPrompterMessages.getString("prompt.lineprompt"), //$NON-NLS-1$
-                    in.readNextLine());
+                    buf.readLine());
             in.type("2"); //$NON-NLS-1$
             th.join();
         } catch (IOException | InterruptedException e) {
@@ -293,7 +320,12 @@ public class CLIPrompterTest {
     @Test
     public final void testPromptChoiceConsoleManagerListOfUStringString() {
         try (final PipedConsoleOutput out = new PipedConsoleOutput();
-             PipedConsoleInput in = new PipedConsoleInput()) {
+             PipedOutputStream pout = new PipedOutputStream();
+             PipedInputStream pis = new PipedInputStream(pout);
+             BufferedReader buf = new BufferedReader(
+                     new InputStreamReader(pis, StandardCharsets.UTF_8));
+             PipedConsoleInput in = new PipedConsoleInput(
+                     new PrintStream(pout))) {
             final List<Object> keys = new ArrayList<>();
             keys.add("A choice"); //$NON-NLS-1$
             keys.add("An other"); //$NON-NLS-1$
@@ -305,15 +337,18 @@ public class CLIPrompterTest {
                 @Override
                 public void run() {
                     try {
-                        assertEquals(Integer.valueOf(0),
-                                CLIPrompter.promptChoice(out, in, keys,
+                        assertEquals("Asserted provided value to be retrieved",
+                                Integer.valueOf(0), CLIPrompter.promptChoice(
+                                        out, in, keys, message, cancel));
+                        assertEquals("Asserted provided value to be retrieved",
+                                Integer.valueOf(0), CLIPrompter.promptChoice(
+                                        out, in, keys, message, null));
+                        assertEquals("Asserted provided value to be retrieved",
+                                Integer.valueOf(1), CLIPrompter.promptChoice(
+                                        out, in, keys, message, null));
+                        assertEquals("Asserted provided value to be retrieved",
+                                null, CLIPrompter.promptChoice(out, in, keys,
                                         message, cancel));
-                        assertEquals(Integer.valueOf(0), CLIPrompter
-                                .promptChoice(out, in, keys, message, null));
-                        assertEquals(Integer.valueOf(1), CLIPrompter
-                                .promptChoice(out, in, keys, message, null));
-                        assertEquals(null, CLIPrompter.promptChoice(out, in,
-                                keys, message, cancel));
                     } catch (final IOException e) {
                         fail("Unexpected io excpetion"); //$NON-NLS-1$
                         e.printStackTrace();
@@ -326,7 +361,7 @@ public class CLIPrompterTest {
             assertTrue(out.readNextLine().contains(keys.get(1).toString()));
             assertTrue(out.readNextLine().contains(cancel));
             assertEquals(CLIPrompterMessages.getString("prompt.lineprompt"), //$NON-NLS-1$
-                    in.readNextLine());
+                    buf.readLine());
             in.type("yoyo"); //$NON-NLS-1$
             // fail, reprompt
             final String msg = CLIPrompterMessages.getString(
@@ -339,14 +374,14 @@ public class CLIPrompterTest {
             assertTrue(out.readNextLine().contains(keys.get(1).toString()));
             assertTrue(out.readNextLine().contains(cancel));
             assertEquals(CLIPrompterMessages.getString("prompt.lineprompt"), //$NON-NLS-1$
-                    in.readNextLine());
+                    buf.readLine());
             in.type("0"); //$NON-NLS-1$
             // Sucess, reprompt without cancel
             assertTrue(out.readNextLine().startsWith(message));
             assertTrue(out.readNextLine().contains(keys.get(0).toString()));
             assertTrue(out.readNextLine().contains(keys.get(1).toString()));
             assertEquals(CLIPrompterMessages.getString("prompt.lineprompt"), //$NON-NLS-1$
-                    in.readNextLine());
+                    buf.readLine());
             in.type("2"); //$NON-NLS-1$
             // fail, reprompt
             assertEquals(
@@ -356,14 +391,14 @@ public class CLIPrompterTest {
             assertTrue(out.readNextLine().contains(keys.get(0).toString()));
             assertTrue(out.readNextLine().contains(keys.get(1).toString()));
             assertEquals(CLIPrompterMessages.getString("prompt.lineprompt"), //$NON-NLS-1$
-                    in.readNextLine());
+                    buf.readLine());
             in.type("0"); //$NON-NLS-1$
             // Success do it again
             assertTrue(out.readNextLine().startsWith(message));
             assertTrue(out.readNextLine().contains(keys.get(0).toString()));
             assertTrue(out.readNextLine().contains(keys.get(1).toString()));
             assertEquals(CLIPrompterMessages.getString("prompt.lineprompt"), //$NON-NLS-1$
-                    in.readNextLine());
+                    buf.readLine());
             in.type("1"); //$NON-NLS-1$
             // Sucess, prompt with cancel
             assertTrue(out.readNextLine().startsWith(message));
@@ -371,7 +406,7 @@ public class CLIPrompterTest {
             assertTrue(out.readNextLine().contains(keys.get(1).toString()));
             assertTrue(out.readNextLine().contains(cancel));
             assertEquals(CLIPrompterMessages.getString("prompt.lineprompt"), //$NON-NLS-1$
-                    in.readNextLine());
+                    buf.readLine());
             in.type("2"); //$NON-NLS-1$
             th.join();
         } catch (IOException | InterruptedException e) {
@@ -385,7 +420,12 @@ public class CLIPrompterTest {
     @Test
     public final void testPromptChoiceConsoleManagerMapOfUTStringString() {
         try (final PipedConsoleOutput out = new PipedConsoleOutput();
-             PipedConsoleInput in = new PipedConsoleInput()) {
+             PipedOutputStream pout = new PipedOutputStream();
+             PipedInputStream pis = new PipedInputStream(pout);
+             BufferedReader buf = new BufferedReader(
+                     new InputStreamReader(pis, StandardCharsets.UTF_8));
+             PipedConsoleInput in = new PipedConsoleInput(
+                     new PrintStream(pout))) {
             final List<Object> keys = new ArrayList<>();
             final Map<Object, Object> choices = new HashMap<>();
             keys.add("A choice"); //$NON-NLS-1$
@@ -400,14 +440,17 @@ public class CLIPrompterTest {
                 @Override
                 public void run() {
                     try {
-                        assertEquals(choices.get(keys.get(0)),
-                                CLIPrompter.promptChoice(out, in, keys,
+                        assertEquals("Asserted provided value to be retrieved",
+                                choices.get(keys.get(0)),
+                                CLIPrompter.promptChoice(out, in, keys, choices,
+                                        message, cancel));
+                        assertEquals("Asserted provided value to be retrieved",
+                                choices.get(keys.get(0)),
+                                CLIPrompter.promptChoice(out, in, keys, choices,
+                                        message, null));
+                        assertEquals("Asserted provided value to be retrieved",
+                                null, CLIPrompter.promptChoice(out, in, keys,
                                         choices, message, cancel));
-                        assertEquals(choices.get(keys.get(0)),
-                                CLIPrompter.promptChoice(out, in, keys,
-                                        choices, message, null));
-                        assertEquals(null, CLIPrompter.promptChoice(out, in,
-                                keys, choices, message, cancel));
                     } catch (final IOException e) {
                         fail("Unexpected io excpetion"); //$NON-NLS-1$
                         e.printStackTrace();
@@ -422,7 +465,7 @@ public class CLIPrompterTest {
             assertTrue(out.readNextLine().contains(keys.get(1).toString()));
             assertTrue(out.readNextLine().contains(cancel));
             assertEquals(CLIPrompterMessages.getString("prompt.lineprompt"), //$NON-NLS-1$
-                    in.readNextLine());
+                    buf.readLine());
             in.type("yoyo"); //$NON-NLS-1$
             // fail, reprompt
             final String msg = CLIPrompterMessages.getString(
@@ -435,14 +478,14 @@ public class CLIPrompterTest {
             assertTrue(out.readNextLine().contains(keys.get(1).toString()));
             assertTrue(out.readNextLine().contains(cancel));
             assertEquals(CLIPrompterMessages.getString("prompt.lineprompt"), //$NON-NLS-1$
-                    in.readNextLine());
+                    buf.readLine());
             in.type("0"); //$NON-NLS-1$
             // Sucess, reprompt without cancel
             assertTrue(out.readNextLine().startsWith(message));
             assertTrue(out.readNextLine().contains(keys.get(0).toString()));
             assertTrue(out.readNextLine().contains(keys.get(1).toString()));
             assertEquals(CLIPrompterMessages.getString("prompt.lineprompt"), //$NON-NLS-1$
-                    in.readNextLine());
+                    buf.readLine());
             in.type("2"); //$NON-NLS-1$
             // fail, reprompt
             assertEquals(
@@ -452,7 +495,7 @@ public class CLIPrompterTest {
             assertTrue(out.readNextLine().contains(keys.get(0).toString()));
             assertTrue(out.readNextLine().contains(keys.get(1).toString()));
             assertEquals(CLIPrompterMessages.getString("prompt.lineprompt"), //$NON-NLS-1$
-                    in.readNextLine());
+                    buf.readLine());
             in.type("0"); //$NON-NLS-1$
             // Sucess, prompt with cancel
             assertTrue(out.readNextLine().startsWith(message));
@@ -460,7 +503,7 @@ public class CLIPrompterTest {
             assertTrue(out.readNextLine().contains(keys.get(1).toString()));
             assertTrue(out.readNextLine().contains(cancel));
             assertEquals(CLIPrompterMessages.getString("prompt.lineprompt"), //$NON-NLS-1$
-                    in.readNextLine());
+                    buf.readLine());
             in.type("2"); //$NON-NLS-1$
             th.join();
         } catch (IOException | InterruptedException e) {
@@ -473,16 +516,23 @@ public class CLIPrompterTest {
      * {@link fr.bigeon.gclc.prompt.CLIPrompter#promptInteger(fr.bigeon.gclc.manager.ConsoleManager, java.lang.String)}. */
     @Test
     public final void testPromptInteger() {
-        try (final PipedConsoleInput test = new PipedConsoleInput()) {
+        try (PipedOutputStream pout = new PipedOutputStream();
+             PipedInputStream pis = new PipedInputStream(pout);
+             BufferedReader buf = new BufferedReader(
+                     new InputStreamReader(pis, StandardCharsets.UTF_8));
+             PipedConsoleInput in = new PipedConsoleInput(
+                     new PrintStream(pout))) {
             final Thread th = new Thread(new Runnable() {
 
                 @Override
                 public void run() {
                     try {
-                        assertEquals(10,
-                                CLIPrompter.promptInteger(test, "My message")); //$NON-NLS-1$
-                        assertEquals(-15,
-                                CLIPrompter.promptInteger(test, "My message")); //$NON-NLS-1$
+                        assertEquals("Asserted provided value to be retrieved",
+                                10,
+                                CLIPrompter.promptInteger(in, "My message")); //$NON-NLS-1$
+                        assertEquals("Asserted provided value to be retrieved",
+                                -15,
+                                CLIPrompter.promptInteger(in, "My message")); //$NON-NLS-1$
                     } catch (final IOException e) {
                         fail("Unexpected io excpetion"); //$NON-NLS-1$
                         e.printStackTrace();
@@ -490,14 +540,14 @@ public class CLIPrompterTest {
                 }
             });
             th.start();
-            assertTrue(test.readNextLine().startsWith("My message")); //$NON-NLS-1$
-            test.type(""); //$NON-NLS-1$
-            assertTrue(test.readNextLine().startsWith("My message")); //$NON-NLS-1$
-            test.type("Y"); //$NON-NLS-1$
-            assertTrue(test.readNextLine().startsWith("My message")); //$NON-NLS-1$
-            test.type("10"); //$NON-NLS-1$
-            assertTrue(test.readNextLine().startsWith("My message")); //$NON-NLS-1$
-            test.type("-15"); //$NON-NLS-1$
+            assertTrue(buf.readLine().startsWith("My message")); //$NON-NLS-1$
+            in.type(""); //$NON-NLS-1$
+            assertTrue(buf.readLine().startsWith("My message")); //$NON-NLS-1$
+            in.type("Y"); //$NON-NLS-1$
+            assertTrue(buf.readLine().startsWith("My message")); //$NON-NLS-1$
+            in.type("10"); //$NON-NLS-1$
+            assertTrue(buf.readLine().startsWith("My message")); //$NON-NLS-1$
+            in.type("-15"); //$NON-NLS-1$
             th.join();
 
         } catch (IOException | InterruptedException e) {
@@ -511,7 +561,12 @@ public class CLIPrompterTest {
     @Test
     public final void testPromptListConsoleManagerString() {
         try (final PipedConsoleOutput out = new PipedConsoleOutput();
-             PipedConsoleInput in = new PipedConsoleInput()) {
+             PipedOutputStream pout = new PipedOutputStream();
+             PipedInputStream pis = new PipedInputStream(pout);
+             BufferedReader buf = new BufferedReader(
+                     new InputStreamReader(pis, StandardCharsets.UTF_8));
+             PipedConsoleInput in = new PipedConsoleInput(
+                     new PrintStream(pout))) {
             final List<String> keys = new ArrayList<>();
             keys.add("A choice"); //$NON-NLS-1$
             keys.add("An other"); //$NON-NLS-1$
@@ -522,10 +577,11 @@ public class CLIPrompterTest {
                 @Override
                 public void run() {
                     try {
-                        assertEquals(new ArrayList<String>(),
-                                CLIPrompter.promptList(out, in, message));
-                        assertEquals(keys,
+                        assertEquals("Asserted provided value to be retrieved",
+                                new ArrayList<String>(),
                                 CLIPrompter.promptList(out, in, message));
+                        assertEquals("Asserted provided value to be retrieved",
+                                keys, CLIPrompter.promptList(out, in, message));
                     } catch (final IOException e) {
                         fail("Unexpected io excpetion"); //$NON-NLS-1$
                         e.printStackTrace();
@@ -539,7 +595,7 @@ public class CLIPrompterTest {
                     .getString("promptlist.exit.dispkey", CLIPrompterMessages //$NON-NLS-1$
                             .getString("promptlist.exit.defaultkey")))); //$NON-NLS-1$
             assertEquals(CLIPrompterMessages.getString("prompt.lineprompt"), //$NON-NLS-1$
-                    in.readNextLine());
+                    buf.readLine());
             in.type(CLIPrompterMessages
                     .getString("promptlist.exit.defaultkey")); //$NON-NLS-1$
             // enter keys list
@@ -549,11 +605,11 @@ public class CLIPrompterTest {
                     .getString("promptlist.exit.dispkey", CLIPrompterMessages //$NON-NLS-1$
                             .getString("promptlist.exit.defaultkey")))); //$NON-NLS-1$
             assertEquals(CLIPrompterMessages.getString("prompt.lineprompt"), //$NON-NLS-1$
-                    in.readNextLine());
+                    buf.readLine());
             for (int i = 0; i < keys.size(); i++) {
                 in.type(keys.get(i));
                 assertEquals(CLIPrompterMessages.getString("prompt.lineprompt"), //$NON-NLS-1$
-                        in.readNextLine());
+                        buf.readLine());
             }
             in.type(CLIPrompterMessages
                     .getString("promptlist.exit.defaultkey")); //$NON-NLS-1$
@@ -569,7 +625,12 @@ public class CLIPrompterTest {
     @Test
     public final void testPromptListConsoleManagerStringString() {
         try (final PipedConsoleOutput out = new PipedConsoleOutput();
-             PipedConsoleInput in = new PipedConsoleInput()) {
+             PipedOutputStream pout = new PipedOutputStream();
+             PipedInputStream pis = new PipedInputStream(pout);
+             BufferedReader buf = new BufferedReader(
+                     new InputStreamReader(pis, StandardCharsets.UTF_8));
+             PipedConsoleInput in = new PipedConsoleInput(
+                     new PrintStream(pout))) {
             final List<String> keys = new ArrayList<>();
             keys.add("A choice"); //$NON-NLS-1$
             keys.add("An other"); //$NON-NLS-1$
@@ -581,10 +642,12 @@ public class CLIPrompterTest {
                 @Override
                 public void run() {
                     try {
-                        assertEquals(new ArrayList<String>(), CLIPrompter
-                                .promptList(out, in, message, ender));
-                        assertEquals(keys, CLIPrompter.promptList(out, in,
-                                message, ender));
+                        assertEquals("Asserted provided value to be retrieved",
+                                new ArrayList<String>(), CLIPrompter
+                                        .promptList(out, in, message, ender));
+                        assertEquals("Asserted provided value to be retrieved",
+                                keys, CLIPrompter.promptList(out, in, message,
+                                        ender));
                     } catch (final IOException e) {
                         fail("Unexpected io excpetion"); //$NON-NLS-1$
                         e.printStackTrace();
@@ -597,7 +660,7 @@ public class CLIPrompterTest {
             assertTrue(nLine.endsWith(CLIPrompterMessages
                     .getString("promptlist.exit.dispkey", ender))); //$NON-NLS-1$
             assertEquals(CLIPrompterMessages.getString("prompt.lineprompt"), //$NON-NLS-1$
-                    in.readNextLine());
+                    buf.readLine());
             in.type(ender);
             // enter keys list
             nLine = out.readNextLine();
@@ -605,11 +668,11 @@ public class CLIPrompterTest {
             assertTrue(nLine.endsWith(CLIPrompterMessages
                     .getString("promptlist.exit.dispkey", ender))); //$NON-NLS-1$
             assertEquals(CLIPrompterMessages.getString("prompt.lineprompt"), //$NON-NLS-1$
-                    in.readNextLine());
+                    buf.readLine());
             for (int i = 0; i < keys.size(); i++) {
                 in.type(keys.get(i));
                 assertEquals(CLIPrompterMessages.getString("prompt.lineprompt"), //$NON-NLS-1$
-                        in.readNextLine());
+                        buf.readLine());
             }
             in.type(ender);
             th.join();
@@ -624,7 +687,12 @@ public class CLIPrompterTest {
     @Test
     public final void testPromptLongTextConsoleManagerString() {
         try (final PipedConsoleOutput out = new PipedConsoleOutput();
-             PipedConsoleInput in = new PipedConsoleInput()) {
+             PipedOutputStream pout = new PipedOutputStream();
+             PipedInputStream pis = new PipedInputStream(pout);
+             BufferedReader buf = new BufferedReader(
+                     new InputStreamReader(pis, StandardCharsets.UTF_8));
+             PipedConsoleInput in = new PipedConsoleInput(
+                     new PrintStream(pout))) {
             final String message = "My message";
             final String longText = "Some text with" + System.lineSeparator() +
                                     "line feeds and other" +
@@ -637,11 +705,12 @@ public class CLIPrompterTest {
                 @Override
                 public void run() {
                     try {
-                        assertEquals("", CLIPrompter.promptLongText(out, in,
-                                message));
-                        assertEquals(longText + System.lineSeparator(),
-                                CLIPrompter.promptLongText(out, in,
-                                        message));
+                        assertEquals("Asserted provided value to be retrieved",
+                                "",
+                                CLIPrompter.promptLongText(out, in, message));
+                        assertEquals("Asserted provided value to be retrieved",
+                                longText + System.lineSeparator(),
+                                CLIPrompter.promptLongText(out, in, message));
                     } catch (final IOException e) {
                         fail("Unexpected io excpetion"); //$NON-NLS-1$
                         e.printStackTrace();
@@ -655,7 +724,7 @@ public class CLIPrompterTest {
                     "promptlongtext.exit.dispkey", CLIPrompterMessages
                             .getString("promptlongtext.exit.defaultkey"))));
             assertEquals(CLIPrompterMessages.getString("prompt.lineprompt"),
-                    in.readNextLine());
+                    buf.readLine());
             in.type(CLIPrompterMessages
                     .getString("promptlongtext.exit.defaultkey"));
             // enter long text
@@ -665,12 +734,12 @@ public class CLIPrompterTest {
                     "promptlongtext.exit.dispkey", CLIPrompterMessages
                             .getString("promptlongtext.exit.defaultkey"))));
             assertEquals(CLIPrompterMessages.getString("prompt.lineprompt"),
-                    in.readNextLine());
+                    buf.readLine());
             final String[] text = longText.split(System.lineSeparator());
             for (final String element : text) {
                 in.type(element);
                 assertEquals(CLIPrompterMessages.getString("prompt.lineprompt"),
-                        in.readNextLine());
+                        buf.readLine());
             }
             in.type(CLIPrompterMessages
                     .getString("promptlongtext.exit.defaultkey"));
@@ -686,7 +755,12 @@ public class CLIPrompterTest {
     @Test
     public final void testPromptLongTextConsoleManagerStringString() {
         try (final PipedConsoleOutput out = new PipedConsoleOutput();
-             PipedConsoleInput in = new PipedConsoleInput()) {
+             PipedOutputStream pout = new PipedOutputStream();
+             PipedInputStream pis = new PipedInputStream(pout);
+             BufferedReader buf = new BufferedReader(
+                     new InputStreamReader(pis, StandardCharsets.UTF_8));
+             PipedConsoleInput in = new PipedConsoleInput(
+                     new PrintStream(pout))) {
             final String message = "My message";
             final String ender = "\\quit";
             final String[] text = new String[] {"Some text with",
@@ -699,10 +773,11 @@ public class CLIPrompterTest {
                 @Override
                 public void run() {
                     try {
-                        assertEquals("", //$NON-NLS-1$
-                                CLIPrompter.promptLongText(out, in, message,
+                        assertEquals("Asserted provided value to be retrieved", //$NON-NLS-1$
+                                "", CLIPrompter.promptLongText(out, in, message,
                                         ender));
-                        assertEquals(longText + System.lineSeparator(),
+                        assertEquals("Asserted provided value to be retrieved",
+                                longText + System.lineSeparator(),
                                 CLIPrompter.promptLongText(out, in, message,
                                         ender));
                     } catch (final IOException e) {
@@ -717,7 +792,7 @@ public class CLIPrompterTest {
             assertTrue(nLine.endsWith(CLIPrompterMessages
                     .getString("promptlongtext.exit.dispkey", ender)));
             assertEquals(CLIPrompterMessages.getString("prompt.lineprompt"),
-                    in.readNextLine());
+                    buf.readLine());
             in.type(ender);
             // enter long text
             nLine = out.readNextLine();
@@ -725,11 +800,11 @@ public class CLIPrompterTest {
             assertTrue(nLine.endsWith(CLIPrompterMessages
                     .getString("promptlongtext.exit.dispkey", ender)));
             assertEquals(CLIPrompterMessages.getString("prompt.lineprompt"),
-                    in.readNextLine());
+                    buf.readLine());
             for (final String element : text) {
                 in.type(element);
                 assertEquals(CLIPrompterMessages.getString("prompt.lineprompt"),
-                        in.readNextLine());
+                        buf.readLine());
             }
             in.type(ender);
             th.join();
@@ -744,7 +819,12 @@ public class CLIPrompterTest {
     @Test
     public final void testPromptMultiChoiceConsoleManagerListOfStringListOfUString() {
         try (final PipedConsoleOutput out = new PipedConsoleOutput();
-             PipedConsoleInput in = new PipedConsoleInput()) {
+             PipedOutputStream pout = new PipedOutputStream();
+             PipedInputStream pis = new PipedInputStream(pout);
+             BufferedReader buf = new BufferedReader(
+                     new InputStreamReader(pis, StandardCharsets.UTF_8));
+             PipedConsoleInput in = new PipedConsoleInput(
+                     new PrintStream(pout))) {
             final List<String> keys = new ArrayList<>();
             final List<Object> choices = new ArrayList<>();
             keys.add("A choice"); //$NON-NLS-1$
@@ -758,15 +838,18 @@ public class CLIPrompterTest {
                 @Override
                 public void run() {
                     try {
-                        assertTrue(CLIPrompter.promptMultiChoice(out, in,
-                                keys, choices, message).isEmpty());
+                        assertTrue("Asserted provided value to be retrieved",
+                                CLIPrompter.promptMultiChoice(out, in, keys,
+                                        choices, message).isEmpty());
                         final ArrayList<Object> l = new ArrayList<>();
                         l.add(choices.get(0));
-                        assertEquals(l, CLIPrompter.promptMultiChoice(out, in,
-                                keys, choices, message));
+                        assertEquals("Asserted provided value to be retrieved",
+                                l, CLIPrompter.promptMultiChoice(out, in, keys,
+                                        choices, message));
                         l.add(choices.get(1));
-                        assertEquals(l, CLIPrompter.promptMultiChoice(out, in,
-                                keys, choices, message));
+                        assertEquals("Asserted provided value to be retrieved",
+                                l, CLIPrompter.promptMultiChoice(out, in, keys,
+                                        choices, message));
                     } catch (final IOException e) {
                         fail("Unexpected io excpetion"); //$NON-NLS-1$
                         e.printStackTrace();
@@ -778,7 +861,7 @@ public class CLIPrompterTest {
             assertTrue(out.readNextLine().contains(keys.get(0)));
             assertTrue(out.readNextLine().contains(keys.get(1)));
             assertEquals(CLIPrompterMessages.getString("prompt.lineprompt"), //$NON-NLS-1$
-                    in.readNextLine());
+                    buf.readLine());
             in.type("yoyo"); //$NON-NLS-1$
             // fail, reprompt
             final String msg = CLIPrompterMessages.getString(
@@ -790,14 +873,14 @@ public class CLIPrompterTest {
             assertTrue(out.readNextLine().contains(keys.get(0)));
             assertTrue(out.readNextLine().contains(keys.get(1)));
             assertEquals(CLIPrompterMessages.getString("prompt.lineprompt"), //$NON-NLS-1$
-                    in.readNextLine());
+                    buf.readLine());
             in.type(""); //$NON-NLS-1$
             // Sucess, reprompt without cancel
             assertTrue(out.readNextLine().startsWith(message));
             assertTrue(out.readNextLine().contains(keys.get(0)));
             assertTrue(out.readNextLine().contains(keys.get(1)));
             assertEquals(CLIPrompterMessages.getString("prompt.lineprompt"), //$NON-NLS-1$
-                    in.readNextLine());
+                    buf.readLine());
             in.type("2"); //$NON-NLS-1$
             // fail, reprompt
             assertEquals(
@@ -807,14 +890,14 @@ public class CLIPrompterTest {
             assertTrue(out.readNextLine().contains(keys.get(0)));
             assertTrue(out.readNextLine().contains(keys.get(1)));
             assertEquals(CLIPrompterMessages.getString("prompt.lineprompt"), //$NON-NLS-1$
-                    in.readNextLine());
+                    buf.readLine());
             in.type("0"); //$NON-NLS-1$
             // Sucess, prompt with cancel
             assertTrue(out.readNextLine().startsWith(message));
             assertTrue(out.readNextLine().contains(keys.get(0)));
             assertTrue(out.readNextLine().contains(keys.get(1)));
             assertEquals(CLIPrompterMessages.getString("prompt.lineprompt"), //$NON-NLS-1$
-                    in.readNextLine());
+                    buf.readLine());
             in.type("0 1"); //$NON-NLS-1$
             th.join();
         } catch (IOException | InterruptedException e) {
@@ -828,7 +911,12 @@ public class CLIPrompterTest {
     @Test
     public final void testPromptMultiChoiceConsoleManagerListOfUMapOfUTString() {
         try (final PipedConsoleOutput out = new PipedConsoleOutput();
-             PipedConsoleInput in = new PipedConsoleInput()) {
+             PipedOutputStream pout = new PipedOutputStream();
+             PipedInputStream pis = new PipedInputStream(pout);
+             BufferedReader buf = new BufferedReader(
+                     new InputStreamReader(pis, StandardCharsets.UTF_8));
+             PipedConsoleInput in = new PipedConsoleInput(
+                     new PrintStream(pout))) {
             final List<Object> keys = new ArrayList<>();
             final Map<Object, Object> choices = new HashMap<>();
             keys.add("A choice"); //$NON-NLS-1$
@@ -842,15 +930,18 @@ public class CLIPrompterTest {
                 @Override
                 public void run() {
                     try {
-                        assertTrue(CLIPrompter.promptMultiChoice(out, in,
-                                keys, choices, message).isEmpty());
+                        assertTrue("Asserted provided value to be retrieved",
+                                CLIPrompter.promptMultiChoice(out, in, keys,
+                                        choices, message).isEmpty());
                         final ArrayList<Object> l = new ArrayList<>();
                         l.add(choices.get(keys.get(0)));
-                        assertEquals(l, CLIPrompter.promptMultiChoice(out, in,
-                                keys, choices, message));
+                        assertEquals("Asserted provided value to be retrieved",
+                                l, CLIPrompter.promptMultiChoice(out, in, keys,
+                                        choices, message));
                         l.add(choices.get(keys.get(1)));
-                        assertEquals(l, CLIPrompter.promptMultiChoice(out, in,
-                                keys, choices, message));
+                        assertEquals("Asserted provided value to be retrieved",
+                                l, CLIPrompter.promptMultiChoice(out, in, keys,
+                                        choices, message));
                     } catch (final IOException e) {
                         fail("Unexpected io excpetion"); //$NON-NLS-1$
                         e.printStackTrace();
@@ -862,7 +953,7 @@ public class CLIPrompterTest {
             assertTrue(out.readNextLine().contains(keys.get(0).toString()));
             assertTrue(out.readNextLine().contains(keys.get(1).toString()));
             assertEquals(CLIPrompterMessages.getString("prompt.lineprompt"), //$NON-NLS-1$
-                    in.readNextLine());
+                    buf.readLine());
             in.type("yoyo"); //$NON-NLS-1$
             // fail, reprompt
             final String msg = CLIPrompterMessages.getString(
@@ -874,14 +965,14 @@ public class CLIPrompterTest {
             assertTrue(out.readNextLine().contains(keys.get(0).toString()));
             assertTrue(out.readNextLine().contains(keys.get(1).toString()));
             assertEquals(CLIPrompterMessages.getString("prompt.lineprompt"), //$NON-NLS-1$
-                    in.readNextLine());
+                    buf.readLine());
             in.type(""); //$NON-NLS-1$
             // Sucess, reprompt without cancel
             assertTrue(out.readNextLine().startsWith(message));
             assertTrue(out.readNextLine().contains(keys.get(0).toString()));
             assertTrue(out.readNextLine().contains(keys.get(1).toString()));
             assertEquals(CLIPrompterMessages.getString("prompt.lineprompt"), //$NON-NLS-1$
-                    in.readNextLine());
+                    buf.readLine());
             in.type("2"); //$NON-NLS-1$
             // fail, reprompt
             assertEquals(
@@ -891,14 +982,14 @@ public class CLIPrompterTest {
             assertTrue(out.readNextLine().contains(keys.get(0).toString()));
             assertTrue(out.readNextLine().contains(keys.get(1).toString()));
             assertEquals(CLIPrompterMessages.getString("prompt.lineprompt"), //$NON-NLS-1$
-                    in.readNextLine());
+                    buf.readLine());
             in.type("0"); //$NON-NLS-1$
             // Sucess, prompt with cancel
             assertTrue(out.readNextLine().startsWith(message));
             assertTrue(out.readNextLine().contains(keys.get(0).toString()));
             assertTrue(out.readNextLine().contains(keys.get(1).toString()));
             assertEquals(CLIPrompterMessages.getString("prompt.lineprompt"), //$NON-NLS-1$
-                    in.readNextLine());
+                    buf.readLine());
             in.type("0 1"); //$NON-NLS-1$
             th.join();
         } catch (IOException | InterruptedException e) {
@@ -912,7 +1003,12 @@ public class CLIPrompterTest {
     @Test
     public final void testPromptMultiChoiceConsoleManagerListOfUString() {
         try (final PipedConsoleOutput out = new PipedConsoleOutput();
-             PipedConsoleInput in = new PipedConsoleInput()) {
+             PipedOutputStream pout = new PipedOutputStream();
+             PipedInputStream pis = new PipedInputStream(pout);
+             BufferedReader buf = new BufferedReader(
+                     new InputStreamReader(pis, StandardCharsets.UTF_8));
+             PipedConsoleInput in = new PipedConsoleInput(
+                     new PrintStream(pout))) {
             final List<Object> keys = new ArrayList<>();
             keys.add("A choice"); //$NON-NLS-1$
             keys.add("An other"); //$NON-NLS-1$
@@ -923,16 +1019,18 @@ public class CLIPrompterTest {
                 @Override
                 public void run() {
                     try {
-                        assertTrue(CLIPrompter
-                                .promptMultiChoice(out, in, keys, message)
-                                .isEmpty());
+                        assertTrue("Asserted provided value to be retrieved",
+                                CLIPrompter.promptMultiChoice(out, in, keys,
+                                        message).isEmpty());
                         final ArrayList<Integer> l = new ArrayList<>();
                         l.add(0);
-                        assertEquals(l, CLIPrompter.promptMultiChoice(out, in,
-                                keys, message));
+                        assertEquals("Asserted provided value to be retrieved",
+                                l, CLIPrompter.promptMultiChoice(out, in, keys,
+                                        message));
                         l.add(1);
-                        assertEquals(l, CLIPrompter.promptMultiChoice(out, in,
-                                keys, message));
+                        assertEquals("Asserted provided value to be retrieved",
+                                l, CLIPrompter.promptMultiChoice(out, in, keys,
+                                        message));
                     } catch (final IOException e) {
                         fail("Unexpected io excpetion"); //$NON-NLS-1$
                         e.printStackTrace();
@@ -944,7 +1042,7 @@ public class CLIPrompterTest {
             assertTrue(out.readNextLine().contains(keys.get(0).toString()));
             assertTrue(out.readNextLine().contains(keys.get(1).toString()));
             assertEquals(CLIPrompterMessages.getString("prompt.lineprompt"), //$NON-NLS-1$
-                    in.readNextLine());
+                    buf.readLine());
             in.type("yoyo"); //$NON-NLS-1$
             // fail, reprompt
             final String msg = CLIPrompterMessages.getString(
@@ -956,14 +1054,14 @@ public class CLIPrompterTest {
             assertTrue(out.readNextLine().contains(keys.get(0).toString()));
             assertTrue(out.readNextLine().contains(keys.get(1).toString()));
             assertEquals(CLIPrompterMessages.getString("prompt.lineprompt"), //$NON-NLS-1$
-                    in.readNextLine());
+                    buf.readLine());
             in.type(""); //$NON-NLS-1$
             // Sucess, reprompt without cancel
             assertTrue(out.readNextLine().startsWith(message));
             assertTrue(out.readNextLine().contains(keys.get(0).toString()));
             assertTrue(out.readNextLine().contains(keys.get(1).toString()));
             assertEquals(CLIPrompterMessages.getString("prompt.lineprompt"), //$NON-NLS-1$
-                    in.readNextLine());
+                    buf.readLine());
             in.type("2"); //$NON-NLS-1$
             // fail, reprompt
             assertEquals(
@@ -973,14 +1071,14 @@ public class CLIPrompterTest {
             assertTrue(out.readNextLine().contains(keys.get(0).toString()));
             assertTrue(out.readNextLine().contains(keys.get(1).toString()));
             assertEquals(CLIPrompterMessages.getString("prompt.lineprompt"), //$NON-NLS-1$
-                    in.readNextLine());
+                    buf.readLine());
             in.type("0"); //$NON-NLS-1$
             // Sucess, prompt with cancel
             assertTrue(out.readNextLine().startsWith(message));
             assertTrue(out.readNextLine().contains(keys.get(0).toString()));
             assertTrue(out.readNextLine().contains(keys.get(1).toString()));
             assertEquals(CLIPrompterMessages.getString("prompt.lineprompt"), //$NON-NLS-1$
-                    in.readNextLine());
+                    buf.readLine());
             in.type("0 1"); //$NON-NLS-1$
             th.join();
         } catch (IOException | InterruptedException e) {
@@ -994,7 +1092,12 @@ public class CLIPrompterTest {
     @Test
     public final void testPromptMultiChoiceConsoleManagerMapOfUTString() {
         try (final PipedConsoleOutput out = new PipedConsoleOutput();
-             PipedConsoleInput in = new PipedConsoleInput()) {
+             PipedOutputStream pout = new PipedOutputStream();
+             PipedInputStream pis = new PipedInputStream(pout);
+             BufferedReader buf = new BufferedReader(
+                     new InputStreamReader(pis, StandardCharsets.UTF_8));
+             PipedConsoleInput in = new PipedConsoleInput(
+                     new PrintStream(pout))) {
             final List<Object> keys = new ArrayList<>();
             final Map<Object, Object> choices = new HashMap<>();
             keys.add("A choice"); //$NON-NLS-1$
@@ -1008,15 +1111,18 @@ public class CLIPrompterTest {
                 @Override
                 public void run() {
                     try {
-                        assertTrue(CLIPrompter.promptMultiChoice(out, in, keys,
-                                choices, message).isEmpty());
+                        assertTrue("Asserted provided value to be retrieved",
+                                CLIPrompter.promptMultiChoice(out, in, keys,
+                                        choices, message).isEmpty());
                         final ArrayList<Object> l = new ArrayList<>();
                         l.add(choices.get(keys.get(0)));
-                        assertEquals(l, CLIPrompter.promptMultiChoice(out, in,
-                                keys, choices, message));
+                        assertEquals("Asserted provided value to be retrieved",
+                                l, CLIPrompter.promptMultiChoice(out, in, keys,
+                                        choices, message));
                         l.add(choices.get(keys.get(1)));
-                        assertEquals(l, CLIPrompter.promptMultiChoice(out, in,
-                                keys, choices, message));
+                        assertEquals("Asserted provided value to be retrieved",
+                                l, CLIPrompter.promptMultiChoice(out, in, keys,
+                                        choices, message));
                     } catch (final IOException e) {
                         fail("Unexpected io excpetion"); //$NON-NLS-1$
                         e.printStackTrace();
@@ -1069,15 +1175,21 @@ public class CLIPrompterTest {
      * {@link fr.bigeon.gclc.prompt.CLIPrompter#promptNonEmpty(fr.bigeon.gclc.manager.ConsoleManager, java.lang.String, java.lang.String)}. */
     @Test
     public final void testPromptNonEmpty() {
-        try (final PipedConsoleInput test = new PipedConsoleInput()) {
+        try (PipedOutputStream pout = new PipedOutputStream();
+             PipedInputStream pis = new PipedInputStream(pout);
+             BufferedReader buf = new BufferedReader(
+                     new InputStreamReader(pis, StandardCharsets.UTF_8));
+             PipedConsoleInput in = new PipedConsoleInput(
+                     new PrintStream(pout))) {
             final String res = "some content"; //$NON-NLS-1$
             final Thread th = new Thread(new Runnable() {
 
                 @Override
                 public void run() {
                     try {
-                        assertEquals(res, CLIPrompter.promptNonEmpty(test,
-                                "My message", "my reprompt")); //$NON-NLS-1$ //$NON-NLS-2$
+                        assertEquals("Expected provided message to be returned",
+                                res, CLIPrompter.promptNonEmpty(in,
+                                        "My message", "my reprompt")); //$NON-NLS-1$ //$NON-NLS-2$
                     } catch (final IOException e) {
                         fail("Unexpected io excpetion"); //$NON-NLS-1$
                         e.printStackTrace();
@@ -1085,10 +1197,10 @@ public class CLIPrompterTest {
                 }
             });
             th.start();
-            assertTrue(test.readNextLine().startsWith("My message")); //$NON-NLS-1$
-            test.type(""); //$NON-NLS-1$
-            assertTrue(test.readNextLine().startsWith("my reprompt")); //$NON-NLS-1$
-            test.type(res);
+            assertTrue(buf.readLine().startsWith("My message")); //$NON-NLS-1$
+            in.type(""); //$NON-NLS-1$
+            assertTrue(buf.readLine().startsWith("my reprompt")); //$NON-NLS-1$
+            in.type(res);
             th.join();
 
         } catch (IOException | InterruptedException e) {