From ff9ace1033b0a08791ba6b9a85e5e7d8a37bf269 Mon Sep 17 00:00:00 2001
From: Emmanuel Bigeon <emmanuel@bigeon.fr>
Date: Tue, 6 Dec 2016 12:56:42 -0500
Subject: [PATCH] Fix test for getWaitRunnable

---
 .../bigeon/gclc/manager/ReadingRunnableTest.java  | 15 +++++----------
 1 file changed, 5 insertions(+), 10 deletions(-)

diff --git a/gclc/src/test/java/fr/bigeon/gclc/manager/ReadingRunnableTest.java b/gclc/src/test/java/fr/bigeon/gclc/manager/ReadingRunnableTest.java
index 15f991d..0bb2c18 100644
--- a/gclc/src/test/java/fr/bigeon/gclc/manager/ReadingRunnableTest.java
+++ b/gclc/src/test/java/fr/bigeon/gclc/manager/ReadingRunnableTest.java
@@ -48,6 +48,7 @@ import java.io.InputStream;
 import java.io.InputStreamReader;
 import java.io.PipedInputStream;
 import java.io.PipedOutputStream;
+import java.nio.charset.Charset;
 
 import org.junit.Before;
 import org.junit.Test;
@@ -110,17 +111,15 @@ public class ReadingRunnableTest {
             final ReadingRunnable runnable = new ReadingRunnable(reader);
             Thread th0 = new Thread(runnable, "read");
             th0.start();
-            Thread th = runnable.getWaitForDelivery("");
+            Thread th = runnable.getWaitForDelivery("msg");
 
-            final Object start = new Object();
+            out.write(Charset.forName("UTF-8")
+                    .encode("msg" + System.lineSeparator()).array());
 
             Thread th2 = new Thread(new Runnable() {
 
                 @Override
                 public void run() {
-                    synchronized (start) {
-                        start.notify();
-                    }
                     try {
                         runnable.getMessage();
                     } catch (IOException e) {
@@ -129,11 +128,7 @@ public class ReadingRunnableTest {
                     }
                 }
             }, "get");
-            synchronized (start) {
-                th2.start();
-                start.wait();
-            }
-            runnable.interrupt();
+            th2.start();
             try {
                 th.join();
             } catch (InterruptedException e) {