[Jenkins] Dependency Updates

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

gclc-process/pom.xml

@@ -3,7 +3,7 @@
 	<parent>
 		<groupId>net.bigeon.config</groupId>
 		<artifactId>ebigeon-config</artifactId>
-		<version>1.8.21</version>
+		<version>1.8.33</version>
 	</parent>
 
 	<groupId>net.bigeon.gclc</groupId>
@@ -38,7 +38,7 @@
 	</developers>
 	<scm>
 		<tag>HEAD</tag>
-		<developerConnection>scm:git:gogs@git.code.bigeon.net:emmanuel/gclc.git</developerConnection>
+		<developerConnection>scm:git:gitea@git.code.bigeon.net:emmanuel/gclc-core.git</developerConnection>
 	</scm>
 	<properties>
 		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
@@ -49,12 +49,12 @@
 		<dependency>
 			<groupId>net.bigeon</groupId>
 			<artifactId>gclc</artifactId>
-			<version>2.1.0</version>
+			<version>2.1.5</version>
 		</dependency>
 		<dependency>
 			<groupId>net.bigeon.test</groupId>
 			<artifactId>junitmt</artifactId>
-			<version>1.0.2</version>
+			<version>1.0.4</version>
 			<scope>test</scope>
 		</dependency>
 	</dependencies>

gclc-process/src/main/java/net/bigeon/gclc/process/ForkTask.java

@@ -100,7 +100,7 @@ public abstract class ForkTask implements Task {
     /** Create the task.
      * 
      * @param lines the number of print to store in the output */
-    public ForkTask(final int lines) {
+    protected ForkTask(final int lines) {
         out = new ConnectingConsoleOutput(ConnectingConsoleOutput.PERSIST, lines);
     }
 
@@ -142,15 +142,18 @@ public abstract class ForkTask implements Task {
      * @param timeout the maximal time to join for (0 for ever) */
     public final void join(final ConsoleOutput out, final ConsoleInput in,
             final long timeout) {
+        final long tic = System.currentTimeMillis();
         synchronized (runLock) {
             this.out.connect(out);
             this.in.connect(in);
-            try {
-                if (running) {
+            long tac = System.currentTimeMillis() - tic;
+            while (running && tac < timeout) {
+                try {
                     runLock.wait(timeout);
+                } catch (final InterruptedException e) {
+                    Thread.currentThread().interrupt();
                 }
-            } catch (final InterruptedException e) {
-                Thread.currentThread().interrupt();
+                tac = System.currentTimeMillis() - tic;
             }
             this.out.disconnect();
             this.in.disconnect();

gclc-process/src/main/java/net/bigeon/gclc/process/TaskSpawner.java

@@ -84,8 +84,8 @@ public abstract class TaskSpawner extends Command {
     private final ExecutorService threadPool;
 
     /** @param name the command name
-     * @param pool the pool */
-    public TaskSpawner(final String name, final TaskPool pool,
+     * @param threadPool the pool */
+    protected TaskSpawner(final String name, final TaskPool pool,
                        final ExecutorService threadPool) {
         super(name);
         this.pool = pool;

gclc-process/src/main/java/net/bigeon/gclc/process/io/ConnectingConsoleInput.java

@@ -72,20 +72,16 @@ import java.io.InterruptedIOException;
 import java.util.function.Supplier;
 
 import net.bigeon.gclc.manager.ConsoleInput;
-import net.bigeon.gclc.tools.ConstantString;
 
 /** A console input that can be connected to and diconnected from.
  * 
  * @author Emmanuel Bigeon */
 public final class ConnectingConsoleInput implements ConsoleInput {
 
-    /** The empty string provider. */
-    private static final ConstantString EMPTY_STRING = new ConstantString("");
-
     /** If the input is closed. */
     private boolean          close          = false;
     /** The prompt string. */
-    private Supplier<String> prompt         = EMPTY_STRING;
+    private Supplier<String> prompt         = () -> "";
     /** If the input is currently in prompting state.
      * <p>
      * To change it you should be in a promptLock. */
@@ -210,10 +206,18 @@ public final class ConnectingConsoleInput implements ConsoleInput {
         return doPrompt(message, timeout, tic);
     }
 
+    /** Actually do the prompting
+     * 
+     * @param message the prompt message
+     * @param timeout the time to wait for an answer
+     * @param tic the moment the wait started
+     * @return the message provided through the prompting
+     * @throws IOException if an IO error occurred while prompting. */
     private String doPrompt(final String message, final long timeout, final long tic)
             throws IOException {
         do {
             if (!checkPrompt()) {
+                // We are not prompting... lets stop here.
                 break;
             }
             getConnection(getTimeoutLeft(tic, timeout));
@@ -224,10 +228,13 @@ public final class ConnectingConsoleInput implements ConsoleInput {
                 actualConnected = connected;
             }
             if (!connect) {
+                // There is no provide of input... So lets start again, until we actually
+                // DO get a provider of input.
                 continue;
             }
             try {
                 final String res = actualPrompt(message, timeout, tic, actualConnected);
+                // We got something from the prompting
                 synchronized (promptLock) {
                     if (prompting) {
                         prompting = false;
@@ -286,10 +293,10 @@ public final class ConnectingConsoleInput implements ConsoleInput {
     }
 
     private void getConnection(final long timeout) throws InterruptedIOException {
-        boolean connect;
+        final long tic = System.currentTimeMillis();
         synchronized (connectionLock) {
-            connect = connected != null;
-            if (!connect) {
+            while ((connected == null || !interrupting)
+                    && (tic + timeout) > System.currentTimeMillis()) {
                 try {
                     connectionLock.wait(timeout);
                 } catch (final InterruptedException e) {
@@ -307,7 +314,7 @@ public final class ConnectingConsoleInput implements ConsoleInput {
      * @see fr.bigeon.gclc.manager.ConsoleInput#setPrompt(java.lang.String) */
     @Override
     public void setPrompt(final String prompt) {
-        this.prompt = new ConstantString(prompt);
+        this.prompt = () -> prompt;
     }
 
     /* (non-Javadoc)

gclc-process/src/test/java/net/bigeon/gclc/process/io/ConnectingConsoleInputTest.java

@@ -1,10 +1,6 @@
 package net.bigeon.gclc.process.io;
 
-import static org.junit.Assert.assertEquals;
-import static org.junit.Assert.assertFalse;
-import static org.junit.Assert.assertNull;
-import static org.junit.Assert.assertTrue;
-import static org.junit.Assert.fail;
+import static org.junit.Assert.*;
 
 import java.io.IOException;
 import java.io.InterruptedIOException;
@@ -12,16 +8,16 @@ import java.io.PipedInputStream;
 import java.io.PipedOutputStream;
 import java.nio.charset.StandardCharsets;
 import java.util.concurrent.atomic.AtomicBoolean;
+import java.util.function.Supplier;
 
 import org.junit.Test;
 
 import net.bigeon.gclc.manager.PipedConsoleInput;
 import net.bigeon.gclc.manager.StreamConsoleInput;
-import net.bigeon.gclc.tools.ConstantString;
-import net.bigeon.test.junitmt.ATestRunnable;
 import net.bigeon.test.junitmt.FunctionalTestRunnable;
-import net.bigeon.test.junitmt.TestFunction;
 import net.bigeon.test.junitmt.ThreadTest;
+import net.bigeon.test.junitmt.api.ATestRunnable;
+import net.bigeon.test.junitmt.api.TestFunction;
 
 public class ConnectingConsoleInputTest {
 
@@ -67,9 +63,8 @@ public class ConnectingConsoleInputTest {
     public void testCoveragePrompt() {
         final ConnectingConsoleInput in = new ConnectingConsoleInput();
         in.setPrompt("test");
-        assertEquals("Prompt should be set correctly", "test",
-                ((ConstantString) in.getPrompt()).get());
-        final ConstantString prompt = new ConstantString("other");
+        assertEquals("Prompt should be set correctly", "test", in.getPrompt().get());
+        final Supplier<String> prompt = () -> "other";
         in.setPrompt(prompt);
         assertEquals("Prompt should be set correctly", prompt, in.getPrompt());
     }
@@ -79,51 +74,43 @@ public class ConnectingConsoleInputTest {
         final ConnectingConsoleInput in = new ConnectingConsoleInput();
         // Unconnected
         final AtomicBoolean ended = new AtomicBoolean(false);
-        final TestFunction one = new TestFunction() {
-
-            @Override
-            public void apply() throws Exception {
+        final TestFunction one = () -> {
+            try {
+                final String res1 = in.prompt("m1", -1);
+                fail("interruption of infinite waiting prompt should cause error, but was "
+                        + res1);
+            } catch (final InterruptedIOException e1) {
+                // ok
+            }
+            try {
+                final String res2 = in.prompt("m2", 25000);
+                fail("interruption of finite waiting prompt should cause error, but was "
+                        + res2);
+            } catch (final InterruptedIOException e2) {
+                // ok
+            }
+            synchronized (ended) {
+                ended.set(true);
                 try {
-                    final String res = in.prompt("m1", -1);
-                    fail("interruption of infinite waiting prompt should cause error, but was "
-                            + res);
-                } catch (final InterruptedIOException e) {
-                    // ok
-                }
-                try {
-                    final String res = in.prompt("m2", 25000);
-                    fail("interruption of finite waiting prompt should cause error, but was "
-                            + res);
-                } catch (final InterruptedIOException e) {
-                    // ok
-                }
-                synchronized (ended) {
-                    ended.set(true);
-                    try {
-                        assertNull("Overtime should return null", in.prompt("m3", 200));
-                    } catch (final InterruptedIOException e) {
-                        fail("Unexpected interruption error in overtime");
-                    }
+                    assertNull("Overtime should return null", in.prompt("m3", 200));
+                } catch (final InterruptedIOException e3) {
+                    fail("Unexpected interruption error in overtime");
                 }
             }
         };
         final ATestRunnable runnable = new FunctionalTestRunnable(one);
-        final Thread th = new Thread(runnable);
-        final Thread inter = new Thread(new Runnable() {
-
-            @Override
-            public void run() {
-                while (!ended.get()) {
-                    try {
-                        th.join(100);
-                    } catch (final InterruptedException e) {
-                        // TODO Auto-generated catch block
-                        e.printStackTrace();
-                    }
-                    synchronized (ended) {
-                        if (!ended.get()) {
-                            in.interruptPrompt();
-                        }
+        final Thread th = new Thread(runnable, "TestPromptSequence");
+        final Thread inter = new Thread(() -> {
+            while (!ended.get()) {
+                try {
+                    th.join(100);
+                } catch (final InterruptedException e) {
+                    // TODO Auto-generated catch block
+                    e.printStackTrace();
+                }
+                synchronized (ended) {
+                    if (!ended.get()) {
+                        in.interruptPrompt();
                     }
                 }
             }
@@ -139,21 +126,17 @@ public class ConnectingConsoleInputTest {
         in.connect(new StreamConsoleInput(null, pis, StandardCharsets.UTF_8));
         final ATestRunnable runnable2 = new FunctionalTestRunnable(one);
         final Thread th2 = new Thread(runnable2);
-        final Thread inter2 = new Thread(new Runnable() {
-
-            @Override
-            public void run() {
-                while (!ended.get()) {
-                    try {
-                        th2.join(100);
-                    } catch (final InterruptedException e) {
-                        // TODO Auto-generated catch block
-                        e.printStackTrace();
-                    }
-                    synchronized (ended) {
-                        if (!ended.get()) {
-                            in.interruptPrompt();
-                        }
+        final Thread inter2 = new Thread(() -> {
+            while (!ended.get()) {
+                try {
+                    th2.join(100);
+                } catch (final InterruptedException e) {
+                    // TODO Auto-generated catch block
+                    e.printStackTrace();
+                }
+                synchronized (ended) {
+                    if (!ended.get()) {
+                        in.interruptPrompt();
                     }
                 }
             }

gclc-socket/pom.xml

@@ -3,11 +3,11 @@
 	<parent>
 		<groupId>net.bigeon.config</groupId>
 		<artifactId>ebigeon-public-conf</artifactId>
-		<version>1.0.10</version>
+		<version>1.0.12</version>
 	</parent>
 	<groupId>net.bigeon.gclc</groupId>
 	<artifactId>socket</artifactId>
-	<version>1.1.17</version>
+	<version>1.1.19-SNAPSHOT</version>
 	<packaging>jar</packaging>
 	<name>GCLC Socket</name>
 	<description>Socket implementation of GCLC</description>
@@ -35,8 +35,8 @@
 		</developer>
 	</developers>
 	<scm>
-		<developerConnection>scm:git:gogs@git.code.bigeon.net:emmanuel/gclc.git</developerConnection>
-		<tag>socket-1.1.17</tag>
+		<developerConnection>scm:git:gitea@git.code.bigeon.net:emmanuel/gclc-core.git</developerConnection>
+		<tag>HEAD</tag>
 	</scm>
 	<properties>
 		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
@@ -46,17 +46,17 @@
 		<dependency>
 			<groupId>net.bigeon</groupId>
 			<artifactId>gclc</artifactId>
-			<version>2.1.0</version>
+			<version>2.1.5</version>
 		</dependency>
 		<dependency>
 			<groupId>net.bigeon</groupId>
 			<artifactId>smu</artifactId>
-			<version>1.0.7</version>
+			<version>1.1.2</version>
 		</dependency>
 		<dependency>
 			<groupId>net.bigeon.test</groupId>
 			<artifactId>junitmt</artifactId>
-			<version>1.0.2</version>
+			<version>1.0.4</version>
 			<scope>test</scope>
 		</dependency>
 	</dependencies>

gclc-socket/src/main/java/net/bigeon/gclc/socket/PluggableConsoleInput.java

@@ -51,7 +51,6 @@ import java.util.logging.Level;
 import java.util.logging.Logger;
 
 import net.bigeon.gclc.manager.ConsoleInput;
-import net.bigeon.gclc.tools.ConstantString;
 import net.bigeon.gclc.utils.ReadingRunnable;
 
 /** A console input where the stream can be plugged.
@@ -78,7 +77,7 @@ public final class PluggableConsoleInput implements ConsoleInput {
     /** If the element is closed. */
     private boolean             closed      = false;
     /** The default prompt. */
-    private Supplier<String>    prompt      = new ConstantString("> "); //$NON-NLS-1$
+    private Supplier<String>    prompt      = () -> "> ";     //$NON-NLS-1$
     /** If the input is plugged or buffering. */
     private boolean             connected   = false;
     /** The current connexion (if any). */
@@ -263,7 +262,7 @@ public final class PluggableConsoleInput implements ConsoleInput {
      * @see net.bigeon.gclc.manager.ConsoleInput#setPrompt(java.lang.String) */
     @Override
     public void setPrompt(final String prompt) {
-        setPrompt(new ConstantString(prompt));
+        setPrompt(() -> prompt);
     }
 
     /* (non-Javadoc)
@@ -294,7 +293,9 @@ public final class PluggableConsoleInput implements ConsoleInput {
                     brutalDisconnection();
                 }
             }
-            connexionLock.wait(connexionTimeout);
+            while (!connected) {
+                connexionLock.wait(connexionTimeout);
+            }
         }
         return null;
     }
@@ -310,4 +311,23 @@ public final class PluggableConsoleInput implements ConsoleInput {
             listener.disconnected();
         }
     }
+
+    /** Add a listener to the list of listeners.
+     * 
+     * @param e the listener
+     * @return if the listener was added
+     * @see java.util.Set#add(java.lang.Object) */
+    public boolean add(final DisconnexionListener e) {
+        return listeners.add(e);
+    }
+
+    /** Remove a listener from the list of listeners.
+     * 
+     * @param o the listener
+     * @return if the listener was removed
+     * @see java.util.Set#remove(java.lang.Object) */
+    public boolean remove(final DisconnexionListener o) {
+        return listeners.remove(o);
+    }
+
 }

gclc-socket/src/main/java/net/bigeon/gclc/socket/RemoteDisconnectCommand.java

@@ -4,46 +4,8 @@
  */
 package net.bigeon.gclc.socket;
 
-/*-
- * #%L
- * GCLC Socket
- * %%
- * Copyright (C) 2016 - 2018 Bigeon
- * %%
- * This software is governed by the CeCILL  license under French law and
- * abiding by the rules of distribution of free software.  You can  use,
- * modify and/ or redistribute the software under the terms of the CeCILL
- * license as circulated by CEA, CNRS and INRIA at the following URL
- * "http://www.cecill.info".
- *
- * As a counterpart to the access to the source code and  rights to copy,
- * modify and redistribute granted by the license, users are provided only
- * with a limited warranty  and the software's author,  the holder of the
- * economic rights,  and the successive licensors  have only  limited
- * liability.
- *
- * In this respect, the user's attention is drawn to the risks associated
- * with loading,  using,  modifying and/or developing or reproducing the
- * software by the user in light of its specific status of free software,
- * that may mean  that it is complicated to manipulate,  and  that  also
- * therefore means  that it is reserved for developers  and  experienced
- * professionals having in-depth computer knowledge. Users are therefore
- * encouraged to load and test the software's suitability as regards their
- * requirements in conditions enabling the security of their systems and/or
- * data to be ensured and,  more generally, to use and operate it in the
- * same conditions as regards security.
- *
- * The fact that you are presently reading this means that you have had
- * knowledge of the CeCILL license and that you accept its terms.
- * #L%
- */
-import java.io.IOException;
-import java.text.MessageFormat;
-import java.util.Collection;
-
 import net.bigeon.gclc.command.Command;
 import net.bigeon.gclc.exception.CommandRunException;
-import net.bigeon.gclc.exception.CommandRunExceptionType;
 import net.bigeon.gclc.manager.ConsoleInput;
 import net.bigeon.gclc.manager.ConsoleOutput;
 
@@ -56,11 +18,7 @@ import net.bigeon.gclc.manager.ConsoleOutput;
 @Deprecated
 public final class RemoteDisconnectCommand<T> extends Command {
 
-    /** The connexion manager. */
-    private final ConnexionManager<T> manager;
-    /** If all connexion should be disconnected when no argument have been
-     * specified. */
-    private final boolean             all;
+    private final net.bigeon.gclc.socket.cmd.RemoteDisconnectCommand<T> real;
 
     /** Create the disconnection command.
      *
@@ -71,8 +29,8 @@ public final class RemoteDisconnectCommand<T> extends Command {
     public RemoteDisconnectCommand(final String name, final ConnexionManager<T> manager,
                                    final boolean all) {
         super(name);
-        this.manager = manager;
-        this.all = all;
+        real = new net.bigeon.gclc.socket.cmd.RemoteDisconnectCommand<>(name, manager,
+                all);
     }
 
     /* (non-Javadoc)
@@ -81,52 +39,20 @@ public final class RemoteDisconnectCommand<T> extends Command {
     @Override
     public void execute(final ConsoleOutput out, final ConsoleInput in,
             final String... args) throws CommandRunException {
-        if (args.length == 0 && all) {
-            final Collection<String> coll = manager.getConnected();
-            for (final String string : coll) {
-                manager.disconnect(string);
-            }
-        }
-        for (final String string : args) {
-            if (manager.isConnected(string)) {
-                manager.disconnect(string);
-            } else {
-                print(out,
-                        MessageFormat.format("[WARNING] {0} is not connected", string)); //$NON-NLS-1$
-            }
-        }
-    }
-
-    /** Print a message if the output is defined.
-     *
-     * @param out the output
-     * @param string the message
-     * @throws CommandRunException if the output exists but cannot be printed to */
-    private static void print(final ConsoleOutput out, final String string)
-            throws CommandRunException {
-        if (out != null) {
-            try {
-                out.println(string);
-            } catch (final IOException e) {
-                throw new CommandRunException(CommandRunExceptionType.INTERACTION,
-                        "Unable to print to existing output", e); //$NON-NLS-1$
-            }
-        }
+        real.execute(out, in, args);
     }
 
     /* (non-Javadoc)
      * @see fr.bigeon.gclc.command.ICommand#tip() */
     @Override
     public String tip() {
-        return "Close a connexion."; //$NON-NLS-1$
+        return real.tip();
     }
 
     /* (non-Javadoc)
      * @see fr.bigeon.gclc.command.Command#usageDetail() */
     @Override
     protected String usageDetail() {
-        return MessageFormat.format(
-                "  If arguments are provided the corresponding connexions are closed, otherwise\n{0} are.",
-                all ? "all connexions" : "none");
+        return "";
     }
 }

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

@@ -77,6 +77,8 @@ public final class SocketConsoleApplicationShell implements Runnable {
     /** The application. */
     private ConsoleApplication       app;
 
+    private final Object initLock = new Object();
+
     /** The server socket. */
     private ServerSocket      serverSocket;
     /** THe server address. */
@@ -123,7 +125,10 @@ public final class SocketConsoleApplicationShell implements Runnable {
         // Create the server
         try (ServerSocket actualServerSocket = new ServerSocket(port, 1, addr)) {
             serverSocket = actualServerSocket;
-            running = true;
+            synchronized (initLock) {
+                running = true;
+                initLock.notifyAll();
+            }
             // Create the streams
             runSokectServer();
         } catch (final IOException e) {
@@ -194,4 +199,23 @@ public final class SocketConsoleApplicationShell implements Runnable {
             LOGGER.log(Level.SEVERE, "Exception in closing socket server", e); //$NON-NLS-1$
         }
     }
+
+    /** A method to wait for the socket server initialization.
+     * 
+     * @param timeout the timeout */
+    public void waitStartUp(final long timeout) {
+        synchronized (initLock) {
+            final long tic = System.currentTimeMillis() + timeout;
+            long tac;
+            while (!running && (tac = System.currentTimeMillis()) < tic) {
+                final long idle = tic - tac;
+                try {
+                    initLock.wait(idle);
+                } catch (final InterruptedException e) {
+                    LOGGER.log(Level.INFO, "Thread interruption", e);
+                    Thread.currentThread().interrupt();
+                }
+            }
+        }
+    }
 }

gclc-socket/src/main/java/net/bigeon/gclc/socket/cmd/RemoteDisconnectCommand.java

@@ -123,8 +123,14 @@ public final class RemoteDisconnectCommand<T> extends Command {
      * @see fr.bigeon.gclc.command.Command#usageDetail() */
     @Override
     protected String usageDetail() {
-        return MessageFormat.format(
-                "  If arguments are provided the corresponding connexions are closed, otherwise\n{0} are.",
-                all ? "all connexions" : "none");
+        final StringBuilder builder = new StringBuilder(
+                "  If arguments are provided the corresponding connexions are closed, otherwise\n");
+        if (all) {
+            builder.append("all connections");
+        } else {
+            builder.append("none");
+        }
+        builder.append(" are.");
+        return builder.toString();
     }
 }

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

@@ -66,6 +66,7 @@ public class TestServer {
         if (server == null) {
             server = new Thread(getShell(), "gclcServer");
             server.start();
+            getShell().waitStartUp(500);
         }
         return server;
     }
@@ -82,13 +83,7 @@ public class TestServer {
             SHELL.setInterface(new SocketConsoleInterface(input, output));
             SHELL.setConnexionManager(manager);
             SHELL.setApplication(app);
-            final Thread th = new Thread(new Runnable() {
-
-                @Override
-                public void run() {
-                    app.start();
-                }
-            });
+            final Thread th = new Thread(() -> app.start());
             th.start();
             try {
                 final Object waiting = new Object();

gclc-swt/pom.xml

@@ -3,11 +3,11 @@
 	<parent>
 		<groupId>net.bigeon.config</groupId>
 		<artifactId>swt-public-conf</artifactId>
-		<version>1.0.1</version>
+		<version>1.0.2</version>
 	</parent>
 	<groupId>net.bigeon.gclc</groupId>
 	<artifactId>swt</artifactId>
-	<version>1.2.1-SNAPSHOT</version>
+	<version>1.2.2-SNAPSHOT</version>
 	<packaging>jar</packaging>
 	<name>GCLC swt</name>
 	<description>A swt window for console applications</description>
@@ -35,7 +35,7 @@
 		</developer>
 	</developers>
 	<scm>
-		<developerConnection>scm:git:gogs@git.code.bigeon.net:emmanuel/gclc.git</developerConnection>
+		<developerConnection>scm:git:gitea@git.code.bigeon.net:emmanuel/gclc-core.git</developerConnection>
 		<tag>HEAD</tag>
 	</scm>
 	<properties>
@@ -48,27 +48,26 @@
 		<dependency>
 			<groupId>net.bigeon</groupId>
 			<artifactId>gclc</artifactId>
-			<version>2.1.0</version>
+			<version>2.1.5</version>
 		</dependency>
 		<dependency>
 			<groupId>net.bigeon</groupId>
 			<artifactId>collections</artifactId>
-			<version>1.2.6</version>
+			<version>1.3.5</version>
 		</dependency>
 		<dependency>
 			<groupId>org.mockito</groupId>
 			<artifactId>mockito-core</artifactId>
-			<version>2.27.0</version>
+			<version>5.15.2</version>
 			<scope>test</scope>
 		</dependency>
 	</dependencies>
-
 	<reporting>
 		<plugins>
 			<plugin>
 				<groupId>org.apache.maven.plugins</groupId>
 				<artifactId>maven-javadoc-plugin</artifactId>
-				<version>2.10.3</version>
+				<version>3.0.1</version>
 			</plugin>
 			<plugin>
 				<groupId>com.github.sevntu-checkstyle</groupId>

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

@@ -79,6 +79,11 @@ import org.eclipse.swt.widgets.Text;
 
 import net.bigeon.gclc.manager.PipedConsoleInput;
 import net.bigeon.gclc.manager.PipedConsoleOutput;
+import net.bigeon.gclc.swt.api.ConsoleDelayIO;
+import net.bigeon.gclc.swt.api.ConsoleOutputDisplay;
+import net.bigeon.gclc.swt.io.ConsoleInputManager;
+import net.bigeon.gclc.swt.io.ConsoleOutputManager;
+import net.bigeon.gclc.swt.io.ConsolePromptManager;
 
 /** A shell containing a {@link SWTConsoleView}
  * <p>
@@ -128,12 +133,12 @@ public final class SWTConsole extends Composite {
     }
 
     /** @return the inputManager */
-    public ConsoleInputManager getInputManager() {
+    public ConsoleDelayIO getInputManager() {
         return inputManager;
     }
 
     /** @return the outputManager */
-    public ConsoleOutputManager getOutputManager() {
+    public ConsoleOutputDisplay getOutputManager() {
         return outputManager;
     }
 

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

@@ -78,6 +78,11 @@ import org.eclipse.swt.widgets.Text;
 import net.bigeon.gclc.ConsoleApplication;
 import net.bigeon.gclc.manager.PipedConsoleInput;
 import net.bigeon.gclc.manager.PipedConsoleOutput;
+import net.bigeon.gclc.swt.api.ConsoleDelayIO;
+import net.bigeon.gclc.swt.api.ConsoleOutputDisplay;
+import net.bigeon.gclc.swt.io.ConsoleInputManager;
+import net.bigeon.gclc.swt.io.ConsoleOutputManager;
+import net.bigeon.gclc.swt.tools.HistoryTextKeyListener;
 
 /** A SWT component to connect to gclc {@link ConsoleApplication}.
  *
@@ -129,14 +134,14 @@ public final class SWTConsoleView extends Composite {
     /** Get the manager of console input.
      * 
      * @return the input manager */
-    public ConsoleInputManager getInputManager() {
+    public ConsoleDelayIO getInputManager() {
         return inManager;
     }
 
     /** Get the manager of console output.
      * 
      * @return the output manager */
-    public ConsoleOutputManager getOutputManager() {
+    public ConsoleOutputDisplay getOutputManager() {
         return outManager;
     }
 }

gclc-swt/src/main/java/net/bigeon/gclc/swt/api/ConsoleDelayIO.java

@@ -33,7 +33,7 @@
  * gclc-swt:net.bigeon.gclc.swt.ConsoleDelayIO.java
  * Created on: Nov 19, 2016
  */
-package net.bigeon.gclc.swt;
+package net.bigeon.gclc.swt.api;
 
 import java.io.IOException;
 

gclc-swt/src/main/java/net/bigeon/gclc/swt/api/ConsoleOutputDisplay.java

@@ -1,7 +1,7 @@
 /**
  * 
  */
-package net.bigeon.gclc.swt;
+package net.bigeon.gclc.swt.api;
 
 /*-
  * #%L

gclc-swt/src/main/java/net/bigeon/gclc/swt/api/package-info.java

@@ -0,0 +1,8 @@
+/**
+ * 
+ */
+/**
+ * @author Emmanuel Bigeon
+ *
+ */
+package net.bigeon.gclc.swt.api;

gclc-swt/src/main/java/net/bigeon/gclc/swt/io/ConsoleInputManager.java

@@ -1,7 +1,7 @@
 /**
  * 
  */
-package net.bigeon.gclc.swt;
+package net.bigeon.gclc.swt.io;
 
 /*-
  * #%L
@@ -42,6 +42,7 @@ import java.io.IOException;
 import org.eclipse.swt.widgets.Text;
 
 import net.bigeon.gclc.manager.PipedConsoleInput;
+import net.bigeon.gclc.swt.api.ConsoleDelayIO;
 
 /** The object managing the console input.
  * 

gclc-swt/src/main/java/net/bigeon/gclc/swt/io/ConsoleOutputManager.java

@@ -1,7 +1,7 @@
 /**
  * 
  */
-package net.bigeon.gclc.swt;
+package net.bigeon.gclc.swt.io;
 
 /*-
  * #%L
@@ -40,6 +40,8 @@ package net.bigeon.gclc.swt;
 import org.eclipse.swt.widgets.Text;
 
 import net.bigeon.gclc.manager.PipedConsoleOutput;
+import net.bigeon.gclc.swt.api.ConsoleOutputDisplay;
+import net.bigeon.gclc.swt.tools.TextAppendingRunnable;
 import net.bigeon.gclc.swt.tools.ToSWTConsoleForwardRunnable;
 
 /** The manager for console output to insert in a text.
@@ -94,4 +96,12 @@ public final class ConsoleOutputManager implements ConsoleOutputDisplay {
     public Thread getForwardThread() {
         return forwardThread;
     }
+
+    /** @return the output consumer */
+    public PipedConsoleOutput getManager() {
+        if (forward == null) {
+            return null;
+        }
+        return forward.getOuput();
+    }
 }

gclc-swt/src/main/java/net/bigeon/gclc/swt/io/ConsolePromptManager.java

@@ -1,7 +1,7 @@
 /**
  * 
  */
-package net.bigeon.gclc.swt;
+package net.bigeon.gclc.swt.io;
 
 /*-
  * #%L

gclc-swt/src/main/java/net/bigeon/gclc/swt/io/package-info.java

@@ -0,0 +1,8 @@
+/**
+ * 
+ */
+/**
+ * @author Emmanuel Bigeon
+ *
+ */
+package net.bigeon.gclc.swt.io;

gclc-swt/src/main/java/net/bigeon/gclc/swt/tools/HistoryTextKeyListener.java

@@ -33,7 +33,7 @@
  * gclc-swt:net.bigeon.gclc.swt.HistoryTextKeyListener.java
  * Created on: Jun 9, 2016
  */
-package net.bigeon.gclc.swt;
+package net.bigeon.gclc.swt.tools;
 
 import java.io.IOException;
 import java.util.logging.Level;
@@ -78,6 +78,7 @@ import org.eclipse.swt.events.KeyEvent;
 
 import net.bigeon.collections.Ribbon;
 import net.bigeon.collections.ribbon.ArrayRibbon;
+import net.bigeon.gclc.swt.api.ConsoleDelayIO;
 
 /** A key listener to validate commands and manage the history of commands.
  *

gclc-swt/src/main/java/net/bigeon/gclc/swt/tools/TextAppendingRunnable.java

@@ -1,7 +1,7 @@
 /**
  * 
  */
-package net.bigeon.gclc.swt;
+package net.bigeon.gclc.swt.tools;
 
 import org.eclipse.swt.widgets.Text;
 
@@ -33,4 +33,4 @@ public class TextAppendingRunnable implements Runnable {
         }
         text.append(next);
     }
-}
+}

gclc-swt/src/main/java/net/bigeon/gclc/swt/tools/ToSWTConsoleForwardRunnable.java

@@ -6,14 +6,13 @@ package net.bigeon.gclc.swt.tools;
 import org.eclipse.swt.widgets.Widget;
 
 import net.bigeon.gclc.manager.PipedConsoleOutput;
-import net.bigeon.gclc.manager.forwarding.AOutputForwardRunnable;
-import net.bigeon.gclc.swt.ConsoleOutputDisplay;
+import net.bigeon.gclc.swt.api.ConsoleOutputDisplay;
+import net.bigeon.gclc.tools.AOutputForwardRunnable;
 
 /** The local implementation of the forwarding runnable.
  *
  * @author Emmanuel Bigeon */
-public final class ToSWTConsoleForwardRunnable
-        extends AOutputForwardRunnable {
+public final class ToSWTConsoleForwardRunnable extends AOutputForwardRunnable {
     /** The running status. */
     private boolean                    running = true;
     /** The console output. */
@@ -65,4 +64,4 @@ public final class ToSWTConsoleForwardRunnable
     public PipedConsoleOutput getOuput() {
         return out;
     }
-}
+}

gclc-swt/src/test/java/net/bigeon/gclc/swt/ConsoleInputManagerTest.java

@@ -47,6 +47,7 @@ import org.eclipse.swt.widgets.Text;
 import org.junit.Test;
 
 import net.bigeon.gclc.manager.PipedConsoleInput;
+import net.bigeon.gclc.swt.io.ConsoleInputManager;
 
 /** @author Emmanuel Bigeon */
 public class ConsoleInputManagerTest {
@@ -55,7 +56,7 @@ public class ConsoleInputManagerTest {
     private final ConsoleInputManager cim  = new ConsoleInputManager(text);
 
     /** Test method for
-     * {@link net.bigeon.gclc.swt.ConsoleInputManager#setInput(java.lang.String)}. */
+     * {@link net.bigeon.gclc.swt.io.ConsoleInputManager#setInput(java.lang.String)}. */
     @Test
     public void testSetText() {
         cim.setInput("Text");
@@ -63,7 +64,7 @@ public class ConsoleInputManagerTest {
     }
 
     /** Test method for
-     * {@link net.bigeon.gclc.swt.ConsoleInputManager#validateInput()}.
+     * {@link net.bigeon.gclc.swt.io.ConsoleInputManager#validateInput()}.
      * 
      * @throws IOException if an error occurred */
     @Test
@@ -101,7 +102,7 @@ public class ConsoleInputManagerTest {
     }
 
     /** Test method for
-     * {@link net.bigeon.gclc.swt.ConsoleInputManager#getText()}. */
+     * {@link net.bigeon.gclc.swt.io.ConsoleInputManager#getText()}. */
     @Test
     public void testGetText() {
         assertEquals("Text component should be preserved", text, cim.getText());

gclc-swt/src/test/java/net/bigeon/gclc/swt/ConsoleOutputManagerTest.java

@@ -49,6 +49,7 @@ import org.mockito.invocation.InvocationOnMock;
 import org.mockito.stubbing.Answer;
 
 import net.bigeon.gclc.manager.PipedConsoleOutput;
+import net.bigeon.gclc.swt.io.ConsoleOutputManager;
 
 /** @author Emmanuel Bigeon */
 public class ConsoleOutputManagerTest {
@@ -71,7 +72,7 @@ public class ConsoleOutputManagerTest {
     }
 
     /** Test method for
-     * {@link net.bigeon.gclc.swt.ConsoleOutputManager#appendLine(java.lang.String)}. */
+     * {@link net.bigeon.gclc.swt.io.ConsoleOutputManager#appendLine(java.lang.String)}. */
     @Test
     public void testAppendConsoleOutput() {
         when(text.getText()).thenReturn("", "abc",

gclc-swt/src/test/java/net/bigeon/gclc/swt/ConsolePromptManagerTest.java

@@ -3,6 +3,7 @@
  */
 package net.bigeon.gclc.swt;
 
+import static org.mockito.ArgumentMatchers.any;
 /*-
  * #%L
  * GCLC swt
@@ -36,46 +37,128 @@ package net.bigeon.gclc.swt;
  * knowledge of the CeCILL license and that you accept its terms.
  * #L%
  */
-
-import static org.mockito.Mockito.mock;
-import static org.mockito.Mockito.verify;
+import static org.mockito.Mockito.*;
 
 import java.io.BufferedReader;
+import java.io.IOException;
+import java.util.concurrent.atomic.AtomicInteger;
 
+import org.eclipse.swt.widgets.Display;
 import org.eclipse.swt.widgets.Label;
 import org.junit.Test;
+import org.mockito.Mockito;
+import org.mockito.invocation.InvocationOnMock;
+import org.mockito.stubbing.Answer;
 
-/**
- * @author Emmanuel Bigeon
- *
- */
+import net.bigeon.gclc.swt.io.ConsolePromptManager;
+
+/** @author Emmanuel Bigeon */
 public class ConsolePromptManagerTest {
 
     private final Label label = mock(Label.class);
 
     private final ConsolePromptManager manager = new ConsolePromptManager(label);
 
-    /**
-     * Test method for {@link net.bigeon.gclc.swt.ConsolePromptManager#setPrompt(java.lang.String)}.
-     */
+    /** Test method for
+     * {@link net.bigeon.gclc.swt.io.ConsolePromptManager#setPrompt(java.lang.String)}. */
     @Test
     public void testSetPrompt() {
         manager.setPrompt("abc");
         verify(label).setText("abc");
     }
 
-    /**
-     * Test method for {@link net.bigeon.gclc.swt.ConsolePromptManager#setStream(java.io.BufferedReader)}.
-     */
+    /** Test method for
+     * {@link net.bigeon.gclc.swt.io.ConsolePromptManager#setStream(java.io.BufferedReader)}.
+     * 
+     * @throws IOException if error */
     @Test
-    public void testSetStream() {
+    public void testSetStream() throws IOException {
+        // Create the dispaly, in case...
+        final Display d = mock(Display.class);
+        when(label.getDisplay()).thenReturn(d);
+        Mockito.doAnswer(invocation -> {
+            ((Runnable) invocation.getArgument(0)).run();
+            return null;
+        }).when(d).asyncExec(any(Runnable.class));
+        Mockito.doAnswer(invocation -> {
+            ((Runnable) invocation.getArgument(0)).run();
+            return null;
+        }).when(d).syncExec(any(Runnable.class));
+        // Test.
         BufferedReader output = mock(BufferedReader.class);
+        final Object lock = new Object();
+        final AtomicInteger calls = new AtomicInteger(0);
+        Mockito.when(output.readLine()).then(new Answer<String>() {
+            String[] ans = { "A line" };
+
+            @Override
+            public String answer(final InvocationOnMock invocation) throws Throwable {
+                synchronized (lock) {
+                    if (calls.get() >= ans.length) {
+                        calls.incrementAndGet();
+                        lock.notify();
+                        return null;
+                    }
+                    lock.notify();
+                    return ans[calls.getAndIncrement()];
+                }
+            }
+        });
         manager.setStream(output);
         manager.setStream(output);
+        synchronized (lock) {
+            while (calls.get() < 2) {
+                try {
+                    lock.wait(10);
+                } catch (final InterruptedException e) {
+                    // TODO Auto-generated catch block
+                    e.printStackTrace();
+                }
+            }
+        }
+        verify(output, times(2)).readLine();
         output = mock(BufferedReader.class);
+        calls.set(0);
+        Mockito.when(output.readLine()).then(new Answer<String>() {
+            String[] ans = { "A line" };
+
+            @Override
+            public String answer(final InvocationOnMock invocation) throws Throwable {
+                synchronized (lock) {
+                    if (calls.get() >= ans.length) {
+                        calls.incrementAndGet();
+                        lock.notify();
+                        return null;
+                    }
+                    lock.notify();
+                    return ans[calls.getAndIncrement()];
+                }
+            }
+        });
         manager.setStream(output);
+        while (calls.get() < 2) {
+            synchronized (lock) {
+                try {
+                    lock.wait(10);
+                } catch (final InterruptedException e) {
+                    // TODO Auto-generated catch block
+                    e.printStackTrace();
+                }
+            }
+        }
         manager.setStream(null);
         manager.setStream(output);
+        while (calls.get() < 3) {
+            synchronized (lock) {
+                try {
+                    lock.wait(10);
+                } catch (final InterruptedException e) {
+                    // TODO Auto-generated catch block
+                    e.printStackTrace();
+                }
+            }
+        }
+        verify(output, times(3)).readLine();
+        verify(label, times(2)).setText("A line");
     }
-
 }

gclc-swt/src/test/java/net/bigeon/gclc/swt/HistoryTextKeyListenerTest.java

@@ -69,11 +69,17 @@ package net.bigeon.gclc.swt;
  * #L%
  */
 import static org.junit.Assert.assertEquals;
-import static org.mockito.Mockito.mock;
+import static org.mockito.Mockito.*;
+
+import java.io.IOException;
 
 import org.eclipse.swt.SWT;
 import org.eclipse.swt.events.KeyEvent;
 import org.junit.Test;
+import org.mockito.Mockito;
+
+import net.bigeon.gclc.swt.api.ConsoleDelayIO;
+import net.bigeon.gclc.swt.tools.HistoryTextKeyListener;
 
 /**
  * <p>
@@ -83,7 +89,7 @@ import org.junit.Test;
 public class HistoryTextKeyListenerTest {
 
     /** Test method for
-     * {@link net.bigeon.gclc.swt.HistoryTextKeyListener#keyPressed(org.eclipse.swt.events.KeyEvent)}. */
+     * {@link net.bigeon.gclc.swt.tools.HistoryTextKeyListener#keyPressed(org.eclipse.swt.events.KeyEvent)}. */
     @Test
     public final void testKeyPressedKeyEvent() {
         final ConsoleDelayIO io = new ConsoleDelayIO() {
@@ -142,11 +148,23 @@ public class HistoryTextKeyListenerTest {
     }
 
     @Test
-    public void testKeyPressed() {
+    public void testKeyPressedA() throws IOException {
         final ConsoleDelayIO io = mock(ConsoleDelayIO.class);
         final KeyEvent event = mock(KeyEvent.class);
         event.keyCode = 'a';
         final HistoryTextKeyListener listener = new HistoryTextKeyListener(io);
         listener.keyPressed(event);
+        verifyNoInteractions(io);
+    }
+
+    @Test
+    public void testKeyPressedReturn() throws IOException {
+        final ConsoleDelayIO io = mock(ConsoleDelayIO.class);
+        Mockito.when(io.getInput()).thenReturn("Alpha");
+        final KeyEvent event = mock(KeyEvent.class);
+        event.keyCode = '\r';
+        final HistoryTextKeyListener listener = new HistoryTextKeyListener(io);
+        listener.keyPressed(event);
+        verify(io, times(1)).validateInput();
     }
 }

gclc-swt/src/test/java/net/bigeon/gclc/swt/PromptReadingRunnableTest.java

@@ -50,8 +50,7 @@ import java.util.logging.Logger;
 import org.eclipse.swt.widgets.Display;
 import org.eclipse.swt.widgets.Label;
 import org.junit.Test;
-import org.mockito.invocation.InvocationOnMock;
-import org.mockito.stubbing.Answer;
+import org.mockito.Mockito;
 
 import net.bigeon.gclc.swt.tools.PromptReadingRunnable;
 
@@ -61,16 +60,10 @@ public class PromptReadingRunnableTest {
     private final Display display = mock(Display.class);
     {
         when(view.getDisplay()).thenReturn(display);
-        doAnswer(new Answer<Object>() {
-            /* (non-Javadoc)
-             * @see
-             * org.mockito.stubbing.Answer#answer(org.mockito.invocation.InvocationOnMock) */
-            @Override
-            public Object answer(final InvocationOnMock invocation) throws Throwable {
-                final Runnable runnable = invocation.getArgument(0);
-                runnable.run();
-                return null;
-            }
+        doAnswer(invocation -> {
+            final Runnable runnable = invocation.getArgument(0);
+            runnable.run();
+            return null;
         }).when(display).syncExec(any(Runnable.class));
     }
 
@@ -85,6 +78,7 @@ public class PromptReadingRunnableTest {
         final PromptReadingRunnable runnable = new PromptReadingRunnable(reader, view);
 
         runnable.run();
+        Mockito.verify(reader, Mockito.times(3)).readLine();
     }
 
     /** Test method for {@link net.bigeon.gclc.swt.tools.PromptReadingRunnable#run()}.
@@ -102,6 +96,7 @@ public class PromptReadingRunnableTest {
 
         runnable.run();
         logger.setLevel(back);
+        Mockito.verify(reader, Mockito.times(1)).readLine();
     }
 
 }

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

@@ -38,6 +38,7 @@ package net.bigeon.gclc.swt;
  */
 
 import static org.junit.Assert.assertNotNull;
+import static org.junit.Assert.assertNull;
 
 import org.eclipse.swt.SWT;
 import org.eclipse.swt.widgets.Composite;
@@ -46,6 +47,7 @@ import org.junit.Test;
 
 import net.bigeon.gclc.manager.PipedConsoleInput;
 import net.bigeon.gclc.manager.PipedConsoleOutput;
+import net.bigeon.gclc.swt.io.ConsoleOutputManager;
 
 /** @author Emmanuel Bigeon */
 public class SWTConsoleShellTest {
@@ -70,6 +72,8 @@ public class SWTConsoleShellTest {
         final SWTConsole console = new SWTConsole(new Shell(), SWT.NONE);
         // Disconnection should work.
         console.connect(null, null, null);
+        assertNull("Console should disconnect",
+                ((ConsoleOutputManager) console.getOutputManager()).getManager());
     }
 
 }

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

@@ -39,6 +39,7 @@ package net.bigeon.gclc.swt;
 
 import static org.junit.Assert.assertFalse;
 import static org.junit.Assert.assertNotNull;
+import static org.junit.Assert.assertNull;
 
 import org.eclipse.swt.SWT;
 import org.eclipse.swt.widgets.Shell;
@@ -46,6 +47,7 @@ import org.junit.Test;
 
 import net.bigeon.gclc.manager.PipedConsoleInput;
 import net.bigeon.gclc.manager.PipedConsoleOutput;
+import net.bigeon.gclc.swt.io.ConsoleOutputManager;
 
 /** @author Emmanuel Bigeon */
 public class SWTConsoleViewTest {
@@ -74,5 +76,7 @@ public class SWTConsoleViewTest {
         final SWTConsoleView view = new SWTConsoleView(new Shell(), SWT.NONE);
         // Disconnection should work.
         view.setManager(null, null);
+        assertNull("Disconnection should replace the input.",
+                ((ConsoleOutputManager) view.getOutputManager()).getManager());
     }
 }

gclc-test/pom.xml

@@ -5,7 +5,7 @@
 	<parent>
 		<groupId>net.bigeon.config</groupId>
 		<artifactId>ebigeon-config</artifactId>
-		<version>1.8.21</version>
+		<version>1.8.33</version>
 	</parent>
 	<groupId>net.bigeon.gclc</groupId>
 	<artifactId>test</artifactId>
@@ -37,7 +37,7 @@
 		</developer>
 	</developers>
 	<scm>
-		<developerConnection>scm:git:gogs@git.code.bigeon.net:emmanuel/gclc.git</developerConnection>
+		<developerConnection>scm:git:gitea@git.code.bigeon.net:emmanuel/gclc-core.git</developerConnection>
 		<tag>HEAD</tag>
 	</scm>
 	<properties>
@@ -49,17 +49,17 @@
 		<dependency>
 			<groupId>net.bigeon</groupId>
 			<artifactId>gclc</artifactId>
-			<version>2.0.12</version>
+			<version>2.1.5</version>
 		</dependency>
 		<dependency>
 			<groupId>junit</groupId>
 			<artifactId>junit</artifactId>
-			<version>4.12</version>
+			<version>4.13.2</version>
 		</dependency>
 		<dependency>
 			<groupId>net.bigeon.test</groupId>
 			<artifactId>junitmt</artifactId>
-			<version>1.0.2</version>
+			<version>1.0.4</version>
 		</dependency>
 	</dependencies>
 	<reporting>
@@ -67,7 +67,7 @@
 			<plugin>
 				<groupId>org.apache.maven.plugins</groupId>
 				<artifactId>maven-javadoc-plugin</artifactId>
-				<version>2.10.3</version>
+				<version>3.0.1</version>
 			</plugin>
 			<plugin>
 				<groupId>com.github.sevntu-checkstyle</groupId>

gclc-test/src/main/java/net/bigeon/gclc/test/InputContract.java

@@ -13,7 +13,6 @@ import java.util.function.Supplier;
 
 import net.bigeon.gclc.manager.ConsoleInput;
 import net.bigeon.test.junitmt.FunctionalTestRunnable;
-import net.bigeon.test.junitmt.TestFunction;
 import net.bigeon.test.junitmt.ThreadTest;
 
 /** @author Emmanuel Bigeon */
@@ -38,24 +37,17 @@ public final class InputContract {
         // Test interruption contract
         final ConsoleInput input2 = inputs.get();
         final FunctionalTestRunnable prompting = new FunctionalTestRunnable(
-                new TestFunction() {
-
-                    @Override
-                    public void apply() throws Exception {
-                        try {
-                            input2.prompt();
-                            fail("Interrupted prompt should throw INterruptedIOException");
-                        } catch (final InterruptedIOException e) {
-                            // ok
-                        }
+                () -> {
+                    try {
+                        input2.prompt();
+                        fail("Interrupted prompt should throw INterruptedIOException");
+                    } catch (final InterruptedIOException e) {
+                        // ok
                     }
                 });
         final Thread th = new Thread(prompting);
         th.start();
-// while (!input2.isPrompting()) {
         th.join(200);
-//
-// }
         input2.interruptPrompt();
         ThreadTest.assertRuns(th, prompting);
     }

gclc-test/src/test/java/net/bigeon/gclc/test/InputContractTest.java

@@ -0,0 +1,52 @@
+/** gclc-test: InputContractTest
+ * Created on Apr. 6, 2020
+ */
+package net.bigeon.gclc.test;
+
+import static org.junit.Assert.fail;
+
+import java.io.File;
+import java.io.IOException;
+import java.io.InputStream;
+import java.io.PipedInputStream;
+import java.io.PipedOutputStream;
+import java.io.PrintStream;
+import java.nio.charset.StandardCharsets;
+
+import org.junit.After;
+import org.junit.Test;
+
+import net.bigeon.gclc.manager.EmptyInput;
+import net.bigeon.gclc.manager.StreamConsoleInput;
+
+/** @author Emmanuel Bigeon */
+public class InputContractTest {
+
+    /** Test method for
+     * {@link net.bigeon.gclc.test.InputContract#testInputContract(java.util.function.Supplier)}. */
+    @Test
+    public void testTestInputContract() throws IOException, InterruptedException {
+        final InputContract contract = new InputContract();
+        try (InputStream in = new PipedInputStream(new PipedOutputStream());
+                PrintStream out = new PrintStream("temp.txt")) {
+            contract.testInputContract(
+                    () -> new StreamConsoleInput(out, in, StandardCharsets.UTF_8));
+        }
+
+        try {
+            contract.testInputContract(() -> EmptyInput.INSTANCE);
+            fail("Empty input does not fit the contract for inputs since it cannot be closed.");
+        } catch (final AssertionError e) {
+            // ok
+        }
+    }
+
+    @After
+    public void tearDown() {
+        final File f = new File("temp.txt");
+        if (f.exists()) {
+            f.delete();
+        }
+    }
+
+}

gclc.system/pom.xml

@@ -3,7 +3,7 @@
 	<parent>
 		<groupId>net.bigeon.config</groupId>
 		<artifactId>ebigeon-config</artifactId>
-		<version>1.8.21</version>
+		<version>1.8.33</version>
 	</parent>
 	<groupId>net.bigeon.gclc</groupId>
 	<artifactId>system</artifactId>
@@ -35,7 +35,7 @@
 		</developer>
 	</developers>
 	<scm>
-		<developerConnection>scm:git:gogs@git.code.bigeon.net:emmanuel/gclc.git</developerConnection>
+		<developerConnection>scm:git:gitea@git.code.bigeon.net:emmanuel/gclc-core.git</developerConnection>
 		<tag>HEAD</tag>
 	</scm>
 	<properties>
@@ -48,12 +48,12 @@
 		<dependency>
 			<groupId>net.bigeon</groupId>
 			<artifactId>gclc</artifactId>
-			<version>2.0.11</version>
+			<version>2.1.5</version>
 		</dependency>
 		<dependency>
 			<groupId>org.mockito</groupId>
 			<artifactId>mockito-core</artifactId>
-			<version>2.23.0</version>
+			<version>5.15.2</version>
 			<scope>test</scope>
 		</dependency>
 	</dependencies>
@@ -67,7 +67,7 @@
 			<plugin>
 				<groupId>org.apache.maven.plugins</groupId>
 				<artifactId>maven-javadoc-plugin</artifactId>
-				<version>2.10.3</version>
+				<version>3.0.1</version>
 			</plugin>
 			<plugin>
 				<groupId>com.github.sevntu-checkstyle</groupId>

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

@@ -101,7 +101,7 @@ public class ExecSystemCommand extends Command {
         try (BufferedWriter writer = new BufferedWriter(new OutputStreamWriter(os))) {
             while (th.isAlive()) {
                 final String user = in.prompt();
-                // Avoid interruption being sent to process.
+                // Forward to process if not empty.
                 if (!user.isEmpty()) {
                     writer.write(user + EOL);
                 }

gclc.system/src/test/java/net/bigeon/gclc/system/ExecSystemCommandTest.java

@@ -33,17 +33,17 @@ package net.bigeon.gclc.system;
  * knowledge of the CeCILL license and that you accept its terms.
  * #L%
  */
-import static org.junit.Assert.assertEquals;
-import static org.junit.Assert.assertNotNull;
-import static org.junit.Assert.fail;
+import static org.junit.jupiter.api.Assertions.assertEquals;
+import static org.junit.jupiter.api.Assertions.assertNotNull;
+import static org.junit.jupiter.api.Assertions.fail;
 
-import org.junit.Test;
+import org.junit.jupiter.api.Test;
 
 import net.bigeon.gclc.exception.CommandRunException;
 import net.bigeon.gclc.manager.ConsoleInput;
 import net.bigeon.gclc.manager.ConsoleOutput;
-import net.bigeon.gclc.utils.EmptyInput;
-import net.bigeon.gclc.utils.SinkOutput;
+import net.bigeon.gclc.manager.EmptyInput;
+import net.bigeon.gclc.manager.SinkOutput;
 
 public class ExecSystemCommandTest {
 
@@ -51,10 +51,10 @@ public class ExecSystemCommandTest {
     @Test
     public void testExecSystemCommand() {
         final ExecSystemCommand cmd = new ExecSystemCommand("test");
-        assertEquals("Name should be preserved", "test", cmd.getCommandName());
-        assertNotNull("tip should be defined", cmd.tip());
-        assertNotNull("usage should be defined", cmd.usagePattern());
-        assertNotNull("usage should be defined", cmd.usageDetail());
+        assertEquals("test", cmd.getCommandName(), "Name should be preserved");
+        assertNotNull(cmd.tip(), "tip should be defined");
+        assertNotNull(cmd.usagePattern(), "usage should be defined");
+        assertNotNull(cmd.usageDetail(), "usage should be detailed");
     }
 
     /** Test the execution of the command.
@@ -79,4 +79,26 @@ public class ExecSystemCommandTest {
         }
     }
 
+    /** Test the execution of the command.
+     * 
+     * @throws CommandRunException if the command fails */
+    @Test
+    public void testLongExecute() throws CommandRunException {
+        final ConsoleOutput out = SinkOutput.INSTANCE;
+        final ConsoleInput in = EmptyInput.INSTANCE;
+
+        final ExecSystemCommand cmd = new ExecSystemCommand();
+        if (System.getProperty("os.name").contains("indows")) {
+            cmd.execute(out, in, "cmd", "/C", "dir", "/s");
+        } else if (System.getProperty("os.name").contains("inux")) {
+            cmd.execute(out, in, "ls", "-R");
+        }
+        try {
+            cmd.execute(out, in, "inexistent");
+            fail("Able to execute inexistent command in system");
+        } catch (final CommandRunException e) {
+            // ok
+        }
+    }
+
 }

gclc.system/src/test/java/net/bigeon/gclc/system/ForwardingRunnableTest.java

@@ -3,18 +3,18 @@
  */
 package net.bigeon.gclc.system;
 
-import static org.junit.Assert.assertTrue;
+import static org.junit.jupiter.api.Assertions.assertInstanceOf;
 
 import java.io.ByteArrayInputStream;
 import java.io.IOException;
 import java.io.InputStream;
 
-import org.junit.Test;
+import org.junit.jupiter.api.Test;
 import org.mockito.Mockito;
 
 import net.bigeon.gclc.exception.CommandRunException;
-import net.bigeon.gclc.utils.SinkOutput;
-import net.bigeon.gclc.utils.StreamConsoleOutput;
+import net.bigeon.gclc.manager.SinkOutput;
+import net.bigeon.gclc.manager.StreamConsoleOutput;
 
 /** @author Emmanuel Bigeon */
 public class ForwardingRunnableTest {
@@ -27,8 +27,8 @@ public class ForwardingRunnableTest {
         // Runnable should close immediatly.
         runnable.run();
 
-        assertTrue("Error should be a CommandRunException",
-                runnable.getError() instanceof CommandRunException);
+        assertInstanceOf(CommandRunException.class, runnable.getError(),
+                "Error should be a CommandRunException");
     }
 
     @Test
@@ -39,6 +39,6 @@ public class ForwardingRunnableTest {
                 is);
         // Runnable should close immediatly.
         runnable.run();
-        assertTrue("Error should be an IO", runnable.getError() instanceof IOException);
+        assertInstanceOf(IOException.class, runnable.getError(), "Error should be an IO");
     }
 }

gclc/pom.xml

@@ -4,11 +4,11 @@
 	<parent>
 		<groupId>net.bigeon.config</groupId>
 		<artifactId>ebigeon-public-conf</artifactId>
-		<version>1.0.10</version>
+		<version>1.0.12</version>
 	</parent>
 	<groupId>net.bigeon</groupId>
 	<artifactId>gclc</artifactId>
-	<version>2.1.1-SNAPSHOT</version>
+	<version>2.1.6-SNAPSHOT</version>
 	<packaging>jar</packaging>
 	<name>Generic Command Ligne console</name>
 	<description>A generic framework for console applications, with customized command input and output streams.</description>
@@ -36,7 +36,7 @@
 		</developer>
 	</developers>
 	<scm>
-		<developerConnection>scm:git:gogs@git.code.bigeon.net:emmanuel/gclc.git</developerConnection>
+		<developerConnection>scm:git:gitea@git.code.bigeon.net:emmanuel/gclc-core.git</developerConnection>
 		<tag>HEAD</tag>
 	</scm>
 	<properties>
@@ -49,7 +49,7 @@
 		<dependency>
 			<groupId>net.bigeon.test</groupId>
 			<artifactId>junitmt</artifactId>
-			<version>1.0.2</version>
+			<version>1.0.4</version>
 			<scope>test</scope>
 		</dependency>
 	</dependencies>

gclc/src/main/java/net/bigeon/gclc/ConsoleApplication.java

@@ -191,7 +191,7 @@ public final class ConsoleApplication implements ICommandProvider {
             args = GCLCConstants.splitCommand(cmd);
         } catch (final CommandParsingException e) {
             out.println("Command line cannot be parsed"); //$NON-NLS-1$
-            LOGGER.log(Level.FINE, "Invalid user command " + cmd, e); //$NON-NLS-1$
+            LOGGER.log(Level.FINE, e, () -> "Invalid user command " + cmd); //$NON-NLS-1$
             return;
         }
         if (!args.isEmpty()) {
@@ -199,7 +199,7 @@ public final class ConsoleApplication implements ICommandProvider {
                 executeSub(out, in, args.get(0),
                         Arrays.copyOfRange(args.toArray(new String[0]), 1, args.size()));
             } catch (final CommandRunException e) {
-                LOGGER.log(Level.FINE, "Command failed: " + cmd, e); //$NON-NLS-1$
+                LOGGER.log(Level.FINE, e, () -> "Command failed: " + cmd); //$NON-NLS-1$
                 out.println(Messages.getString("ConsoleApplication.cmd.failed", cmd)); //$NON-NLS-1$
                 out.println(e.getLocalizedMessage());
                 if (e.getType() == CommandRunExceptionType.USAGE) {

gclc/src/main/java/net/bigeon/gclc/GCLCConstants.java

@@ -146,10 +146,7 @@ public final class GCLCConstants {
                 continue;
             }
             if (c == ' ' && !inString) {
-                final String arg = cmd.substring(startIndex, index - 1);
-                if (!arg.isEmpty()) {
-                    args.add(removeEscaped(arg));
-                }
+                addArgument(args, cmd.substring(startIndex, index - 1));
                 startIndex = index;
             } else if (c == '"') {
                 if (inString) {
@@ -164,9 +161,18 @@ public final class GCLCConstants {
         }
         if (startIndex < cmd.length()) {
             final String arg = cmd.substring(startIndex, cmd.length());
-            args.add(arg);
+            args.add(removeEscaped(arg));
         }
         return args;
     }
 
+    /** Add an argument to the list of arguments if it is not an empty string.
+     * 
+     * @param args the list of argument
+     * @param arg the candidate argument */
+    private static void addArgument(final List<String> args, final String arg) {
+        if (!arg.isEmpty()) {
+            args.add(removeEscaped(arg));
+        }
+    }
 }

gclc/src/main/java/net/bigeon/gclc/command/Command.java

@@ -73,8 +73,11 @@ public abstract class Command implements ICommand {
     /** Create the command.
      *
      * @param name the command name */
-    public Command(final String name) {
+    protected Command(final String name) {
         super();
+        if (name == null) {
+            throw new IllegalArgumentException("The command name is mandatory");
+        }
         this.name = name;
     }
 

gclc/src/main/java/net/bigeon/gclc/command/CommandParameters.java

@@ -103,7 +103,7 @@ public final class CommandParameters {
      * @param key the key
      * @return if the key was specified */
     public boolean isActive(final String key) {
-        Boolean val = booleanArguments.get(key);
+        final Boolean val = booleanArguments.get(key);
         return val != null && val.booleanValue();
     }
 
@@ -198,9 +198,8 @@ public final class CommandParameters {
      * @param string the key
      * @param value the value */
     public void set(final String string, final boolean value) {
-        if (booleanArguments.containsKey(string)) {
-            booleanArguments.put(string, Boolean.valueOf(value));
-        }
+        booleanArguments.computeIfPresent(string,
+                (final String k, final Boolean v) -> Boolean.valueOf(value));
     }
 
     /** Set a string parameter value.
@@ -208,6 +207,9 @@ public final class CommandParameters {
      * @param string the key
      * @param value the value */
     public void set(final String string, final String value) {
+        // DO NOT USE computeIfPresent. This is a HashMap, not a ConcurrentHashMap and
+        // keys can be associated to null, but computeIfPresent will consider them as
+        // absent!
         if (stringArguments.containsKey(string)) {
             stringArguments.put(string, value);
         }

gclc/src/main/java/net/bigeon/gclc/command/ParametrizedCommand.java

@@ -94,7 +94,7 @@ public abstract class ParametrizedCommand extends Command {
      * parameters.
      *
      * @param name the name */
-    public ParametrizedCommand(final String name) {
+    protected ParametrizedCommand(final String name) {
         this(name, true);
     }
 
@@ -106,7 +106,7 @@ public abstract class ParametrizedCommand extends Command {
      *
      * @param name the name
      * @param strict if the arguments are restricted to the declared ones */
-    public ParametrizedCommand(final String name, final boolean strict) {
+    protected ParametrizedCommand(final String name, final boolean strict) {
         super(name);
         data = new ParametrizedCommandData(strict);
     }

gclc/src/main/java/net/bigeon/gclc/command/ParametrizedCommandData.java

@@ -149,14 +149,16 @@ public final class ParametrizedCommandData {
      * @param needed if the parameter is needed
      * @throws InvalidParameterException if the new definition is invalid */
     private void checkParam(final String param, final boolean needed) {
-        final Boolean val = stringParams.get(param);
-        if (val != null) {
-            final Boolean need = Boolean.valueOf(needed || val.booleanValue());
-            stringParams.put(param, need);
+        final Boolean val = stringParams.computeIfPresent(param,
+                (final String k, final Boolean v) -> {
+                    final Boolean need = Boolean.valueOf(needed || v.booleanValue());
             params.put(param, need);
-            return;
+                    return need;
+                });
+        if (val == null) {
+            throw new InvalidParameterException(
+                    "Parameter is already defined as boolean"); //$NON-NLS-1$
         }
-        throw new InvalidParameterException("Parameter is already defined as boolean"); //$NON-NLS-1$
     }
 
     /** Retrieve the boolean parameters (aka flags).

gclc/src/main/java/net/bigeon/gclc/command/base/ScriptExecution.java

@@ -139,7 +139,7 @@ public final class ScriptExecution extends Command {
         try (InputStreamReader fReader = new InputStreamReader(
                 Files.newInputStream(Paths.get(scriptFile)), charset);
                 BufferedReader reader = new BufferedReader(fReader)) {
-            String[] emptyArray = new String[0];
+            final String[] emptyArray = new String[0];
             while ((cmd = reader.readLine()) != null) {
                 lineNo++;
                 final String cmdLine = readCommandLine(cmd, params);
@@ -237,10 +237,16 @@ public final class ScriptExecution extends Command {
      * @return the exception to actually throw */
     private static CommandRunException manageRunException(final CommandRunException e,
             final int lineNo) {
+        final StringBuilder builder = new StringBuilder(e.getLocalizedMessage());
+        int index = builder.indexOf("\n");
+        while (index > 0) {
+            builder.insert(index + 1, "  ");
+            index = builder.indexOf("\n", index + 1);
+        }
         return new CommandRunException(CommandRunExceptionType.EXECUTION,
                 MessageFormat.format(
-                        "The script could not complete due to command failure at line {0} ({1})", //$NON-NLS-1$
-                        Integer.valueOf(lineNo), e.getLocalizedMessage()),
+                        "The script could not complete due to command failure at line {0}\n  {1})", //$NON-NLS-1$
+                        Integer.valueOf(lineNo + 1), builder),
                 e);
     }
 

gclc/src/main/java/net/bigeon/gclc/i18n/Messages.java

@@ -105,8 +105,8 @@ public final class Messages {
         try {
             return MessageFormat.format(RESOURCE_BUNDLE.getString(key), args);
         } catch (final MissingResourceException e) {
-            LOGGER.log(Level.WARNING,
-                    "Unrecognized internationalization message key: " + key, e); //$NON-NLS-1$
+            LOGGER.log(Level.WARNING, e,
+                    () -> "Unrecognized internationalization message key: " + key); //$NON-NLS-1$
             return '!' + key + '!';
         }
     }

gclc/src/main/java/net/bigeon/gclc/manager/ConsoleInput.java

@@ -72,7 +72,6 @@ package net.bigeon.gclc.manager;
  * #L%
  */
 import java.io.IOException;
-import java.io.InterruptedIOException;
 import java.util.function.Supplier;
 
 /** A console application input.
@@ -94,7 +93,7 @@ public interface ConsoleInput extends AutoCloseable {
     /** Indicate to the input that is should interrompt the prompting, if possible.
      * <p>
      * The pending {@link #prompt()} or {@link #prompt(String)} operations should
-     * return immediately by throwing an InterruptedIOException. */
+     * return immediately by throwing an java.io.InterruptedIOException. */
     void interruptPrompt();
 
     /** Test if the input is closed.
@@ -109,7 +108,7 @@ public interface ConsoleInput extends AutoCloseable {
      *
      * @return the user inputed string
      * @throws IOException if the manager is closed or could not read the prompt
-     * @throws InterruptedIOException if the prompt was interrupted */
+     * @throws java.io.InterruptedIOException if the prompt was interrupted */
     String prompt() throws IOException;
 
     /** Prompt the user, with an allotated time to answer.
@@ -117,7 +116,7 @@ public interface ConsoleInput extends AutoCloseable {
      * @param timeout the time to wait in milliseconds
      * @return the user inputed string, null if the timeout was reached
      * @throws IOException if the manager is closed or could not read the prompt
-     * @throws InterruptedIOException if the prompt was interrupted */
+     * @throws java.io.InterruptedIOException if the prompt was interrupted */
     String prompt(long timeout) throws IOException;
 
     /** Prompt the user, with a hint on what is prompted.
@@ -125,7 +124,7 @@ public interface ConsoleInput extends AutoCloseable {
      * @param message the message to prompt the user
      * @return the user inputed string
      * @throws IOException if the manager is closed or could not read the prompt
-     * @throws InterruptedIOException if the prompt was interrupted */
+     * @throws java.io.InterruptedIOException if the prompt was interrupted */
     String prompt(String message) throws IOException;
 
     /** Prompt the user, with a hint on what is prompted and an allotated time to
@@ -135,7 +134,7 @@ public interface ConsoleInput extends AutoCloseable {
      * @param message the message to prompt the user
      * @return the user inputed string, null if the timeout was reached
      * @throws IOException if the manager is closed or could not read the prompt
-     * @throws InterruptedIOException if the prompt was interrupted */
+     * @throws java.io.InterruptedIOException if the prompt was interrupted */
     String prompt(String message, long timeout) throws IOException;
 
     /** Set a prompting prefix.

gclc/src/main/java/net/bigeon/gclc/manager/EmptyInput.java

@@ -40,48 +40,12 @@ package net.bigeon.gclc.manager;
 
 import java.util.function.Supplier;
 
-/*-
- * #%L
- * Generic Command Ligne console
- * %%
- * Copyright (C) 2014 - 2018 Bigeon
- * %%
- * This software is governed by the CeCILL  license under French law and
- * abiding by the rules of distribution of free software.  You can  use,
- * modify and/ or redistribute the software under the terms of the CeCILL
- * license as circulated by CEA, CNRS and INRIA at the following URL
- * "http://www.cecill.info".
- *
- * As a counterpart to the access to the source code and  rights to copy,
- * modify and redistribute granted by the license, users are provided only
- * with a limited warranty  and the software's author,  the holder of the
- * economic rights,  and the successive licensors  have only  limited
- * liability.
- *
- * In this respect, the user's attention is drawn to the risks associated
- * with loading,  using,  modifying and/or developing or reproducing the
- * software by the user in light of its specific status of free software,
- * that may mean  that it is complicated to manipulate,  and  that  also
- * therefore means  that it is reserved for developers  and  experienced
- * professionals having in-depth computer knowledge. Users are therefore
- * encouraged to load and test the software's suitability as regards their
- * requirements in conditions enabling the security of their systems and/or
- * data to be ensured and,  more generally, to use and operate it in the
- * same conditions as regards security.
- *
- * The fact that you are presently reading this means that you have had
- * knowledge of the CeCILL license and that you accept its terms.
- * #L%
- */
-
-import net.bigeon.gclc.tools.ConstantString;
-
 /** A console input that return empty to all prompting.
  *
  * @author Emmanuel Bigeon */
 public final class EmptyInput implements ConsoleInput {
 
-    private static final ConstantString CONSTANT_STRING = new ConstantString("");
+    private static final Supplier<String> CONSTANT_STRING = () -> "";
     /** The empty prompter. */
     public static final ConsoleInput INSTANCE = new EmptyInput();
 

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

@@ -101,13 +101,14 @@ public final class PipedConsoleOutput implements ConsoleOutput {
     private final PrintStream         outPrint;
     /** The reading thread. */
     private final ReadingRunnable     reading;
+    private final PipedOutputStream   out;
 
     /** Create a manager that will write and read through piped stream.
      *
      * @throws IOException if the piping failed for streams */
     public PipedConsoleOutput() throws IOException {
         commandOutput = new PipedInputStream();
-        final PipedOutputStream out = new PipedOutputStream(commandOutput);
+        out = new PipedOutputStream(commandOutput);
         commandBuffOutput = new BufferedReader(
                 new InputStreamReader(commandOutput, StandardCharsets.UTF_8));
         outPrint = new PrintStream(out, true, UTF_8);
@@ -133,6 +134,7 @@ public final class PipedConsoleOutput implements ConsoleOutput {
         reading.setRunning(false);
         innerManager.close();
         outPrint.close();
+        out.close();
         commandBuffOutput.close();
         commandOutput.close();
     }

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

@@ -79,7 +79,6 @@ import java.io.PrintStream;
 import java.nio.charset.Charset;
 import java.util.function.Supplier;
 
-import net.bigeon.gclc.tools.ConstantString;
 import net.bigeon.gclc.utils.ReadingRunnable;
 
 /** A console using the input stream and print stream.
@@ -90,7 +89,7 @@ import net.bigeon.gclc.utils.ReadingRunnable;
 public final class StreamConsoleInput implements ConsoleInput {
 
     /** The default prompt. */
-    public static final Supplier<String> DEFAULT_PROMPT = new ConstantString("> "); //$NON-NLS-1$
+    public static final Supplier<String> DEFAULT_PROMPT = () -> ("> "); //$NON-NLS-1$
 
     /** The command prompt. It can be changed. */
     private Supplier<String> prompt = DEFAULT_PROMPT;
@@ -213,7 +212,7 @@ public final class StreamConsoleInput implements ConsoleInput {
      * @see net.bigeon.gclc.manager.ConsoleInput#setPrompt(java.lang.String) */
     @Override
     public void setPrompt(final String prompt) {
-        this.prompt = new ConstantString(prompt);
+        this.prompt = () -> (prompt);
     }
 
     @Override

gclc/src/main/java/net/bigeon/gclc/manager/forwarding/package-info.java

@@ -1,43 +0,0 @@
-/**
- * 
- */
-/** This package contains the {@link java.lang.Runnable} implementations used to
- * forward messages to or from console output or input.
- * 
- * @author Emmanuel Bigeon */
-package net.bigeon.gclc.manager.forwarding;
-
-/*-
- * #%L
- * Generic Command Ligne console
- * %%
- * Copyright (C) 2014 - 2018 Bigeon
- * %%
- * This software is governed by the CeCILL  license under French law and
- * abiding by the rules of distribution of free software.  You can  use,
- * modify and/ or redistribute the software under the terms of the CeCILL
- * license as circulated by CEA, CNRS and INRIA at the following URL
- * "http://www.cecill.info".
- * 
- * As a counterpart to the access to the source code and  rights to copy,
- * modify and redistribute granted by the license, users are provided only
- * with a limited warranty  and the software's author,  the holder of the
- * economic rights,  and the successive licensors  have only  limited
- * liability.
- * 
- * In this respect, the user's attention is drawn to the risks associated
- * with loading,  using,  modifying and/or developing or reproducing the
- * software by the user in light of its specific status of free software,
- * that may mean  that it is complicated to manipulate,  and  that  also
- * therefore means  that it is reserved for developers  and  experienced
- * professionals having in-depth computer knowledge. Users are therefore
- * encouraged to load and test the software's suitability as regards their
- * requirements in conditions enabling the security of their systems and/or
- * data to be ensured and,  more generally, to use and operate it in the
- * same conditions as regards security.
- * 
- * The fact that you are presently reading this means that you have had
- * knowledge of the CeCILL license and that you accept its terms.
- * #L%
- */
-

gclc/src/main/java/net/bigeon/gclc/tools/AOutputForwardRunnable.java

@@ -36,7 +36,7 @@
  * gclc:net.bigeon.gclc.tools.AOutputForwardRunnable.java
  * Created on: Dec 1, 2016
  */
-package net.bigeon.gclc.manager.forwarding;
+package net.bigeon.gclc.tools;
 
 /*-
  * #%L
@@ -97,7 +97,7 @@ public abstract class AOutputForwardRunnable implements Runnable {
     /** Create a forwarding runnable.
      *
      * @param manager the manager */
-    public AOutputForwardRunnable(final PipedConsoleOutput manager) {
+    protected AOutputForwardRunnable(final PipedConsoleOutput manager) {
         super();
         this.manager = manager;
         timeout = DEFAULT_TIMEOUT;
@@ -116,7 +116,8 @@ public abstract class AOutputForwardRunnable implements Runnable {
      *
      * @param manager the manager
      * @param timeout the timeout between message requests. */
-    public AOutputForwardRunnable(final PipedConsoleOutput manager, final long timeout) {
+    protected AOutputForwardRunnable(final PipedConsoleOutput manager,
+                                     final long timeout) {
         super();
         this.manager = manager;
         this.timeout = timeout;
@@ -156,8 +157,11 @@ public abstract class AOutputForwardRunnable implements Runnable {
     /** a method to wait some time. */
     protected final void waitASec() {
         try {
+            final long tic = System.currentTimeMillis();
             synchronized (this) {
-                wait(timeout);
+                while (System.currentTimeMillis() - tic < timeout) {
+                    wait(timeout + tic - System.currentTimeMillis());
+                }
             }
         } catch (final InterruptedException e) {
             LOGGER.log(Level.SEVERE, "Interrupted wait", //$NON-NLS-1$

gclc/src/main/java/net/bigeon/gclc/tools/ConstantString.java

@@ -73,7 +73,9 @@ import java.util.function.Supplier;
 
 /** A supplier of string that hold a constant string.
  *
- * @author Emmanuel Bigeon */
+ * @author Emmanuel Bigeon
+ * @deprecated since 2.1.2, use a lambda expression instead */
+@Deprecated
 public class ConstantString implements Supplier<String> {
     private final String string;
 

gclc/src/main/java/net/bigeon/gclc/utils/ReadingRunnable.java

@@ -128,8 +128,11 @@ public final class ReadingRunnable implements Runnable {
      * @throws IOException if the runnable was stopped and no essage was found. */
     private void doWaitMessage(final long timeout) throws IOException {
         try {
+            final long tic = System.currentTimeMillis();
             synchronized (lock) {
-                lock.wait(timeout);
+                while (System.currentTimeMillis() - tic < timeout && messages.isEmpty()) {
+                    lock.wait(timeout);
+                }
             }
         } catch (final InterruptedException e) {
             LOGGER.log(Level.SEVERE, THREAD_INTERRUPTION_EXCEPTION, e);
@@ -199,13 +202,13 @@ public final class ReadingRunnable implements Runnable {
     public void waitForDelivery(final String message) throws InterruptedException {
         Object mLock;
         synchronized (messageBlockerLock) {
-            if (!messageBlocker.containsKey(message)) {
-                messageBlocker.put(message, new Object());
-            }
+            messageBlocker.computeIfAbsent(message, (final String k) -> new Object());
             mLock = messageBlocker.get(message);
         }
         synchronized (mLock) {
-            mLock.wait();
+            while (messageBlocker.containsKey(message)) {
+                mLock.wait();
+            }
         }
     }
     
@@ -251,9 +254,9 @@ public final class ReadingRunnable implements Runnable {
             final Object mLock = messageBlocker.get(message);
             if (mLock!=null) {
                 synchronized (mLock) {
+                    messageBlocker.remove(message);
                     mLock.notifyAll();
                 }
-                messageBlocker.remove(message);
             }
         }
     }

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

@@ -71,11 +71,7 @@ package net.bigeon.gclc;
  * knowledge of the CeCILL license and that you accept its terms.
  * #L%
  */
-import static org.junit.Assert.assertEquals;
-import static org.junit.Assert.assertFalse;
-import static org.junit.Assert.assertNotNull;
-import static org.junit.Assert.assertTrue;
-import static org.junit.Assert.fail;
+import static org.junit.Assert.*;
 
 import java.io.BufferedReader;
 import java.io.IOException;

gclc/src/test/java/net/bigeon/gclc/GCLCConstantsTest.java

@@ -72,7 +72,6 @@ package net.bigeon.gclc;
  * #L%
  */
 import static org.junit.Assert.assertEquals;
-import static org.junit.Assert.assertTrue;
 import static org.junit.Assert.fail;
 
 import java.util.List;
@@ -87,52 +86,77 @@ import net.bigeon.gclc.exception.CommandParsingException;
 @SuppressWarnings({ "nls", "static-method" })
 public class GCLCConstantsTest {
 
+    @Test
+    public void testSplitCommandSingle() throws CommandParsingException {
+        List<String> res;
+        res = GCLCConstants.splitCommand("aCommand");
+        assertEquals("single word command should have one element", 1, res.size());
+        assertEquals("Command should be preserved", "aCommand", res.get(0));
+    }
+
+    @Test
+    public void testSplitCommandSeveral() throws CommandParsingException {
+        List<String> res;
+        res = GCLCConstants.splitCommand("aCommand with some arguments");
+        assertEquals("Command size", 4, res.size());
+        assertEquals("Elements should be preserved", "aCommand", res.get(0));
+        assertEquals("Command should be preserved", "with", res.get(1));
+        assertEquals("Command should be preserved", "some", res.get(2));
+        assertEquals("Command should be preserved", "arguments", res.get(3));
+    }
+
     /** Test method for
      * {@link net.bigeon.gclc.GCLCConstants#splitCommand(java.lang.String)}.
      *
      * @throws CommandParsingException if an error occured */
     @Test
-    public void testSplitCommand() throws CommandParsingException {
+    public void testSplitCommandMultiSpaces() throws CommandParsingException {
         List<String> res;
-        res = GCLCConstants.splitCommand("aCommand");
-        assertTrue("single word command should have one element", res.size() == 1);
-        assertTrue("Command should be preserved", res.get(0).equals("aCommand"));
-
-        res = GCLCConstants.splitCommand("aCommand with some arguments");
-        assertEquals("Command size", 4, res.size());
-        assertEquals("Elements should be preserved", "aCommand", res.get(0));
-        assertTrue("Elements should be preserved", res.get(1).equals("with"));
-        assertTrue("Elements should be preserved", res.get(2).equals("some"));
-        assertTrue("Elements should be preserved", res.get(3).equals("arguments"));
         res = GCLCConstants.splitCommand("aCommand with  some arguments");
         assertEquals("Command size", 4, res.size());
-        assertTrue("Elements should be preserved", res.get(0).equals("aCommand"));
-        assertTrue("Elements should be preserved", res.get(1).equals("with"));
-        assertTrue("Elements should be preserved", res.get(2).equals("some"));
-        assertTrue("Elements should be preserved", res.get(3).equals("arguments"));
+        assertEquals("Command should be preserved", "aCommand", res.get(0));
+        assertEquals("Command should be preserved", "with", res.get(1));
+        assertEquals("Command should be preserved", "some", res.get(2));
+        assertEquals("Command should be preserved", "arguments", res.get(3));
+    }
+
+    public void testSplitCommandWithString() throws CommandParsingException {
+        List<String> res;
         res = GCLCConstants.splitCommand("aCommand \"with some\" arguments");
         assertEquals("Command size", 3, res.size());
-        assertTrue("Elements should be preserved", res.get(0).equals("aCommand"));
-        assertTrue("Elements should be preserved", res.get(1).equals("with some"));
-        assertTrue("Elements should be preserved", res.get(2).equals("arguments"));
-        res = GCLCConstants.splitCommand("aCommand with\\ some arguments");
-        assertEquals("Command size", 3, res.size());
-        assertTrue("Elements should be preserved", res.get(0).equals("aCommand"));
-        assertTrue("Elements should be preserved", res.get(1).equals("with some"));
-        assertTrue("Elements should be preserved", res.get(2).equals("arguments"));
-        res = GCLCConstants.splitCommand("aCommand wi\\\"th some arguments");
-        assertEquals("Command size", 4, res.size());
-        assertTrue("Elements should be preserved", res.get(0).equals("aCommand"));
-        assertTrue("Elements should be preserved", res.get(1).equals("wi\"th"));
-        assertTrue("Elements should be preserved", res.get(2).equals("some"));
-        assertTrue("Elements should be preserved", res.get(3).equals("arguments"));
+        assertEquals("Command should be preserved", "aCommand", res.get(0));
+        assertEquals("Command should be preserved", "with some", res.get(1));
+        assertEquals("Command should be preserved", "arguments", res.get(2));
 
         res = GCLCConstants.splitCommand("aCommand with \"some arguments\"");
         assertEquals("Command size", 3, res.size());
-        assertTrue("Elements should be preserved", res.get(0).equals("aCommand"));
-        assertTrue("Elements should be preserved", res.get(1).equals("with"));
-        assertTrue("Elements should be preserved", res.get(2).equals("some arguments"));
+        assertEquals("Command should be preserved", "aCommand", res.get(0));
+        assertEquals("Command should be preserved", "with", res.get(1));
+        assertEquals("Command should be preserved", "some arguments", res.get(2));
+    }
 
+    public void testSplitCommandWithEscape() throws CommandParsingException {
+        List<String> res;
+        res = GCLCConstants.splitCommand("aCommand with\\ some arguments");
+        assertEquals("Command size", 3, res.size());
+        assertEquals("Command should be preserved", "aCommand", res.get(0));
+        assertEquals("Command should be preserved", "with some", res.get(1));
+        assertEquals("Command should be preserved", "arguments", res.get(2));
+    }
+
+    public void testSplitCommandWithQuoteInString() throws CommandParsingException {
+        List<String> res;
+        res = GCLCConstants.splitCommand("aCommand wi\\\"th some arguments");
+        assertEquals("Command size", 4, res.size());
+        assertEquals("Command should be preserved", "aCommand", res.get(0));
+        assertEquals("Command should be preserved", "wi\"th", res.get(1));
+        assertEquals("Command should be preserved", "some", res.get(2));
+        assertEquals("Command should be preserved", "arguments", res.get(3));
+
+    }
+
+    public void testSplitCommandInvalidQuoting() throws CommandParsingException {
+        List<String> res;
         try {
             // Wrong lines?
             res = GCLCConstants.splitCommand("aCommand with \"some ar\"guments");

gclc/src/test/java/net/bigeon/gclc/command/CommandParametersTest.java

@@ -71,11 +71,7 @@ package net.bigeon.gclc.command;
  * knowledge of the CeCILL license and that you accept its terms.
  * #L%
  */
-import static org.junit.Assert.assertEquals;
-import static org.junit.Assert.assertFalse;
-import static org.junit.Assert.assertNull;
-import static org.junit.Assert.assertTrue;
-import static org.junit.Assert.fail;
+import static org.junit.Assert.*;
 
 import java.util.HashSet;
 import java.util.Set;

gclc/src/test/java/net/bigeon/gclc/command/ParametrizedCommandDataTest.java

@@ -33,8 +33,7 @@ package net.bigeon.gclc.command;
  * knowledge of the CeCILL license and that you accept its terms.
  * #L%
  */
-
-import static org.junit.Assert.*;
+import static org.junit.Assert.fail;
 
 import org.junit.Test;
 

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

@@ -71,11 +71,7 @@ package net.bigeon.gclc.command;
  * knowledge of the CeCILL license and that you accept its terms.
  * #L%
  */
-import static org.junit.Assert.assertEquals;
-import static org.junit.Assert.assertFalse;
-import static org.junit.Assert.assertNull;
-import static org.junit.Assert.assertTrue;
-import static org.junit.Assert.fail;
+import static org.junit.Assert.*;
 
 import java.io.BufferedReader;
 import java.io.IOException;
@@ -93,10 +89,10 @@ import net.bigeon.gclc.manager.ConsoleInput;
 import net.bigeon.gclc.manager.ConsoleOutput;
 import net.bigeon.gclc.manager.PipedConsoleInput;
 import net.bigeon.gclc.manager.PipedConsoleOutput;
-import net.bigeon.test.junitmt.ATestRunnable;
 import net.bigeon.test.junitmt.FunctionalTestRunnable;
-import net.bigeon.test.junitmt.TestFunction;
 import net.bigeon.test.junitmt.ThreadTest;
+import net.bigeon.test.junitmt.api.ATestRunnable;
+import net.bigeon.test.junitmt.api.TestFunction;
 
 /**
  * <p>
@@ -513,21 +509,18 @@ public class ParametrizedCommandTest {
             cmd.execute(out, in, "-" + str1, str2, "-" + addParam);
             cmd.execute(out, in, "-" + str1, str2, "-" + addParam, addParam);
 
-            final TestFunction function = new TestFunction() {
-
-                @Override
-                public void apply() throws Exception {
-                    assertEquals("value of " + str1 + "? ", buf.readLine());
-                    in.type("");
-                    assertEquals("value of " + str1 + "? (cannot be empty) ",
-                            buf.readLine());
-                    in.type("");
-                    assertEquals("value of " + str1 + "? (cannot be empty) ",
-                            buf.readLine());
-                    in.type(str2);
-                }
+            final TestFunction function = () -> {
+                assertEquals("value of " + str1 + "? ", buf.readLine());
+                in.type("");
+                assertEquals("value of " + str1 + "? (cannot be empty) ",
+                        buf.readLine());
+                in.type("");
+                assertEquals("value of " + str1 + "? (cannot be empty) ",
+                        buf.readLine());
+                in.type(str2);
             };
-            final ATestRunnable testConsole = new FunctionalTestRunnable(function);
+            final FunctionalTestRunnable testConsole = new FunctionalTestRunnable(
+                    function);
 
             final Thread th = new Thread(testConsole);
             th.start();
@@ -543,13 +536,9 @@ public class ParametrizedCommandTest {
                         new InputStreamReader(pis, StandardCharsets.UTF_8));
                 PipedConsoleInput in = new PipedConsoleInput(new PrintStream(pout))) {
 
-            final TestFunction function = new TestFunction() {
-
-                @Override
-                public void apply() throws Exception {
-                    assertEquals("value of " + str1 + "? ", buf.readLine());
-                    in.type(str2);
-                }
+            final TestFunction function = () -> {
+                assertEquals("value of " + str1 + "? ", buf.readLine());
+                in.type(str2);
             };
             final ATestRunnable testConsole = new FunctionalTestRunnable(function);
 
@@ -565,7 +554,6 @@ public class ParametrizedCommandTest {
             final PipedConsoleInput test = new PipedConsoleInput(null);
             test.close();
             out.close();
-            cmd.execute(out, test, "-" + str1, str2);
             cmd.execute(out, test, "-" + addParam);
             fail("Closed manager shall cause error");
         } catch (final CommandRunException e) {

gclc/src/test/java/net/bigeon/gclc/command/SubedCommandTest.java

@@ -71,10 +71,7 @@ package net.bigeon.gclc.command;
  * knowledge of the CeCILL license and that you accept its terms.
  * #L%
  */
-import static org.junit.Assert.assertEquals;
-import static org.junit.Assert.assertNotNull;
-import static org.junit.Assert.assertNull;
-import static org.junit.Assert.fail;
+import static org.junit.Assert.*;
 
 import java.io.IOException;
 

gclc/src/test/java/net/bigeon/gclc/manager/ReadingRunnableTest.java

@@ -92,8 +92,8 @@ import org.junit.Test;
 
 import net.bigeon.gclc.utils.ReadingRunnable;
 import net.bigeon.test.junitmt.FunctionalTestRunnable;
-import net.bigeon.test.junitmt.TestFunction;
 import net.bigeon.test.junitmt.ThreadTest;
+import net.bigeon.test.junitmt.api.TestFunction;
 
 /**
  * <p>

gclc/src/test/java/net/bigeon/gclc/manager/SystemConsoleManagerTest.java

@@ -71,10 +71,7 @@ package net.bigeon.gclc.manager;
  * knowledge of the CeCILL license and that you accept its terms.
  * #L%
  */
-import static org.junit.Assert.assertEquals;
-import static org.junit.Assert.assertFalse;
-import static org.junit.Assert.assertTrue;
-import static org.junit.Assert.fail;
+import static org.junit.Assert.*;
 
 import java.io.IOException;
 import java.io.InputStream;

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

@@ -71,10 +71,7 @@ package net.bigeon.gclc.prompt;
  * knowledge of the CeCILL license and that you accept its terms.
  * #L%
  */
-import static org.junit.Assert.assertEquals;
-import static org.junit.Assert.assertFalse;
-import static org.junit.Assert.assertTrue;
-import static org.junit.Assert.fail;
+import static org.junit.Assert.*;
 
 import java.io.BufferedReader;
 import java.io.IOException;
@@ -94,10 +91,10 @@ import org.junit.Test;
 
 import net.bigeon.gclc.manager.PipedConsoleInput;
 import net.bigeon.gclc.manager.PipedConsoleOutput;
-import net.bigeon.test.junitmt.ATestRunnable;
 import net.bigeon.test.junitmt.FunctionalTestRunnable;
-import net.bigeon.test.junitmt.TestFunction;
 import net.bigeon.test.junitmt.ThreadTest;
+import net.bigeon.test.junitmt.api.ATestRunnable;
+import net.bigeon.test.junitmt.api.TestFunction;
 
 /**
  * <p>

gclc/src/test/java/net/bigeon/gclc/tools/AOutputForwardRunnableTest.java

@@ -78,7 +78,6 @@ import java.io.IOException;
 import org.junit.Test;
 
 import net.bigeon.gclc.manager.PipedConsoleOutput;
-import net.bigeon.gclc.manager.forwarding.AOutputForwardRunnable;
 
 /**
  * <p>
@@ -143,7 +142,7 @@ public class AOutputForwardRunnableTest {
     }
 
     /** Test method for
-     * {@link net.bigeon.gclc.manager.forwarding.AOutputForwardRunnable#run()}. */
+     * {@link net.bigeon.gclc.tools.AOutputForwardRunnable#run()}. */
     @Test
     public final void testRun() {
         try (PipedConsoleOutput manager = new PipedConsoleOutput()) {