#9275 handle review comments

Signed-off-by: Ludovic Orban <[email protected]>
jetty · Feb 1, 2023 · 618c3e4 · 618c3e4
1 parent eb0ae07
commit 618c3e4
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/...ransports/src/test/java/org/eclipse/jetty/test/client/transport/HttpClientStreamTest.java b/...ransports/src/test/java/org/eclipse/jetty/test/client/transport/HttpClientStreamTest.java
@@ -1146,17 +1146,19 @@ public boolean process(Request request, org.eclipse.jetty.server.Response respon
         });
 
         // Send two parallel requests.
-        client.newRequest(newURI(transport)).send(result -> {});
-        client.newRequest(newURI(transport)).send(result -> {});
+        CountDownLatch clientLatch = new CountDownLatch(2);
+        client.newRequest(newURI(transport)).send(result -> clientLatch.countDown());
+        client.newRequest(newURI(transport)).send(result -> clientLatch.countDown());
 
         // Wait until both requests are in-flight.
         await().atMost(timeoutInSeconds, TimeUnit.SECONDS).until(processCount::get, is(2));
 
         // Stop the client while it has requests in-flight.
         Assertions.assertTimeout(Duration.ofSeconds(timeoutInSeconds), () -> LifeCycle.stop(client));
 
-        // Let the server threads go.
+        // Let the server threads go & wait for the requests to be processed.
         processLatch.countDown();
+        clientLatch.await(timeoutInSeconds, TimeUnit.SECONDS);
     }
 
     private record HandlerContext(Request request, org.eclipse.jetty.server.Response response, Callback callback)