diff --git a/jetty-server/src/test/java/org/eclipse/jetty/server/AsyncCompletionTest.java b/jetty-server/src/test/java/org/eclipse/jetty/server/AsyncCompletionTest.java index bdcefa7625bc..376b9f33baa0 100644 --- a/jetty-server/src/test/java/org/eclipse/jetty/server/AsyncCompletionTest.java +++ b/jetty-server/src/test/java/org/eclipse/jetty/server/AsyncCompletionTest.java @@ -96,7 +96,7 @@ public void proceed() _delay.get(10, TimeUnit.SECONDS); getCallback().succeeded(); } - catch(Throwable th) + catch (Throwable th) { th.printStackTrace(); getCallback().failed(th); @@ -104,7 +104,6 @@ public void proceed() } } - @BeforeEach public void init() throws Exception { @@ -160,7 +159,7 @@ public ExtendedHttpConnection(HttpConfiguration config, Connector connector, End @Override public void onCompleted() { - COMPLETE.compareAndSet(false,true); + COMPLETE.compareAndSet(false, true); super.onCompleted(); } } @@ -170,7 +169,7 @@ public static Stream tests() { List tests = new ArrayList<>(); tests.add(new Object[]{new HelloWorldHandler(), 200, "Hello world"}); - tests.add(new Object[]{new SendErrorHandler(499,"Test async sendError"), 499, "Test async sendError"}); + tests.add(new Object[]{new SendErrorHandler(499, "Test async sendError"), 499, "Test async sendError"}); tests.add(new Object[]{new AsyncReadyCompleteHandler(), 200, AsyncReadyCompleteHandler.data}); return tests.stream().map(Arguments::of); } @@ -205,7 +204,7 @@ public void testAsyncCompletion(Handler handler, int status, String message) thr // wait for threads to return to base level long end = System.nanoTime() + TimeUnit.SECONDS.toNanos(10); - while(_threadPool.getBusyThreads() != base) + while (_threadPool.getBusyThreads() != base) { if (System.nanoTime() > end) throw new TimeoutException(); @@ -218,7 +217,7 @@ public void testAsyncCompletion(Handler handler, int status, String message) thr // proceed with the completion delay.proceed(); - while(!COMPLETE.get()) + while (!COMPLETE.get()) { if (System.nanoTime() > end) throw new TimeoutException(); @@ -236,8 +235,10 @@ public void handle(String target, Request baseRequest, HttpServletRequest reques { AsyncContext context = request.startAsync(); ServletOutputStream out = response.getOutputStream(); - out.setWriteListener(new WriteListener() { + out.setWriteListener(new WriteListener() + { byte[] bytes = data.getBytes(StandardCharsets.ISO_8859_1); + @Override public void onWritePossible() throws IOException {