Make sure to always wait for exhaustion.

org.jgrapes.core/test/org/jgrapes/core/test/basic/StructureTest.java

@@ -91,6 +91,7 @@ public void testDetach() throws InterruptedException, ExecutionException {
         assertNull(comp2.getManager().parent());
         assertEquals(comp2, comp2.getManager().root());
         assertEquals(0, comp.getManager().children().size());
+        Components.awaitExhaustion();
     }
 
     @Test

org.jgrapes.core/test/org/jgrapes/core/test/core/CompletedTest.java

@@ -91,6 +91,7 @@ public void testComplete() throws InterruptedException {
         }
         test1.get();
         assertTrue(app.testDone);
+        Components.awaitExhaustion();
     }
 
 }

org.jgrapes.core/test/org/jgrapes/core/test/core/ErrorTest.java

@@ -54,6 +54,7 @@ public void testDefaultHandler() throws InterruptedException {
         } finally {
             System.setErr(oldErr);
         }
+        Components.awaitExhaustion();
     }
 
     public static class BuggyComponentWithHandler extends Component {
@@ -78,6 +79,7 @@ public void testComplete() throws InterruptedException {
         BuggyComponentWithHandler app = new BuggyComponentWithHandler();
         Components.start(app);
         assertTrue(app.caughtError);
+        Components.awaitExhaustion();
     }
 
 }

org.jgrapes.core/test/org/jgrapes/core/test/core/PriorityTest.java

@@ -64,6 +64,7 @@ public void testComplete() throws InterruptedException {
         PrioritisedHandlers app = new PrioritisedHandlers();
         Components.start(app);
         assertTrue(app.result.equals("Hello"));
+        Components.awaitExhaustion();
     }
 
 }

org.jgrapes.core/test/org/jgrapes/core/test/core/StoppedTest.java

@@ -65,6 +65,7 @@ public void testComplete() throws InterruptedException {
         PrioritisedHandlers app = new PrioritisedHandlers();
         Components.start(app);
         assertTrue(app.result.equals("Hel"));
+        Components.awaitExhaustion();
     }
 
 }

org.jgrapes.io/test/org/jgrapes/io/test/net/EchoTest.java

@@ -190,6 +190,7 @@ public void testTcp() throws IOException, InterruptedException,
             }
             break;
         }
+        Components.awaitExhaustion();
         Components.checkAssertions();
     }
 
@@ -276,6 +277,7 @@ public void checkServerTrusted(
             }
             break;
         }
+        Components.awaitExhaustion();
         Components.checkAssertions();
     }
 

org.jgrapes.io/test/org/jgrapes/io/test/net/EchoTest2.java

@@ -166,6 +166,7 @@ public void testTcp() throws IOException, InterruptedException,
             }
             break;
         }
+        Components.awaitExhaustion();
         Components.checkAssertions();
     }
 
@@ -235,6 +236,7 @@ public void testSsl() throws IOException, InterruptedException,
             }
             break;
         }
+        Components.awaitExhaustion();
         Components.checkAssertions();
     }
 

org.jgrapes.io/test/org/jgrapes/io/test/net/EchoTest3.java

@@ -227,6 +227,7 @@ public void testTcp() throws IOException, InterruptedException,
             }
             break;
         }
+        Components.awaitExhaustion();
         Components.checkAssertions();
     }
 
@@ -276,6 +277,7 @@ public void testUds() throws IOException, InterruptedException,
             }
             break;
         }
+        Components.awaitExhaustion();
         Components.checkAssertions();
         Files.deleteIfExists(udsPath);
     }
@@ -346,6 +348,7 @@ public void testSsl() throws IOException, InterruptedException,
             }
             break;
         }
+        Components.awaitExhaustion();
         Components.checkAssertions();
     }
 

org.jgrapes.io/test/org/jgrapes/io/test/net/SendChunkedTest.java

@@ -185,6 +185,7 @@ public void sendTest(int bufferSize)
             }
             break;
         }
+        Components.awaitExhaustion();
     }
 
 }

org.jgrapes.io/test/org/jgrapes/io/test/net/ServerStateTest.java

@@ -29,6 +29,7 @@
 import org.jgrapes.io.test.WaitForTests;
 import org.jgrapes.net.SocketServer;
 import org.jgrapes.net.events.Ready;
+import org.junit.After;
 import static org.junit.Assert.*;
 import org.junit.Before;
 import org.junit.Test;
@@ -85,6 +86,11 @@ public void setUp() throws Exception {
         wf.get();
     }
 
+    @After
+    public void tearDown() throws Exception {
+        Components.awaitExhaustion();
+    }
+
     @Test
     public void testStartClose() throws InterruptedException {
         assertEquals(State.READY, checker.state);

org.jgrapes.io/test/org/jgrapes/io/test/net/SslEchoServerTest.java

@@ -197,6 +197,7 @@ public void checkServerTrusted(
             }
             break;
         }
+        Components.awaitExhaustion();
         Components.checkAssertions();
     }