Issue #22 - Using Jetty with Spring Webclient causes thread leak.

Added test case - there appear to be no issue though.

Signed-off-by: Simone Bordet <[email protected]>

src/test/java/org/eclipse/jetty/reactive/client/ReactorTest.java

@@ -16,6 +16,9 @@
 package org.eclipse.jetty.reactive.client;
 
 import java.io.IOException;
+import java.io.InterruptedIOException;
+import java.net.URI;
+import java.time.Duration;
 import java.util.Random;
 
 import javax.servlet.http.HttpServletRequest;
@@ -27,6 +30,7 @@
 import org.testng.Assert;
 import org.testng.annotations.Factory;
 import org.testng.annotations.Test;
+import reactor.core.publisher.Mono;
 
 public class ReactorTest extends AbstractTest {
     @Factory(dataProvider = "protocols", dataProviderClass = AbstractTest.class)
@@ -54,4 +58,34 @@ protected void service(String target, Request jettyRequest, HttpServletRequest r
         Assert.assertNotNull(responseContent);
         Assert.assertEquals(data, responseContent);
     }
+
+    @Test
+    public void testTotalTimeout() throws Exception {
+        long timeout = 1000;
+        String result = "HELLO";
+        prepare(new EmptyHandler() {
+            @Override
+            protected void service(String target, Request jettyRequest, HttpServletRequest request, HttpServletResponse response) throws IOException {
+                try {
+                    Thread.sleep(2 * timeout);
+                    response.getWriter().write(result);
+                } catch (InterruptedException x) {
+                    throw new InterruptedIOException();
+                }
+            }
+        });
+
+        String timeoutResult = "TIMEOUT";
+        String responseContent = WebClient.builder()
+                .clientConnector(new JettyClientHttpConnector(httpClient()))
+                .build()
+                .get()
+                .uri(new URI(uri()))
+                .retrieve()
+                .bodyToMono(String.class)
+                .timeout(Duration.ofMillis(timeout), Mono.just(timeoutResult))
+                .block();
+
+        Assert.assertEquals(timeoutResult, responseContent);
+    }
 }