From b60fca3b5939808d9ed39acd064fa098140cefb2 Mon Sep 17 00:00:00 2001 From: Artem Golovko Date: Sun, 26 May 2024 11:10:34 +0100 Subject: [PATCH] Issue #11803 - use static exception for normal completion --- .../org/eclipse/jetty/io/content/ContentSourcePublisher.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/jetty-core/jetty-io/src/main/java/org/eclipse/jetty/io/content/ContentSourcePublisher.java b/jetty-core/jetty-io/src/main/java/org/eclipse/jetty/io/content/ContentSourcePublisher.java index ac635f2a4225..41ececb2234e 100644 --- a/jetty-core/jetty-io/src/main/java/org/eclipse/jetty/io/content/ContentSourcePublisher.java +++ b/jetty-core/jetty-io/src/main/java/org/eclipse/jetty/io/content/ContentSourcePublisher.java @@ -23,6 +23,7 @@ import org.eclipse.jetty.io.Content; import org.eclipse.jetty.util.IteratingCallback; import org.eclipse.jetty.util.MathUtils; +import org.eclipse.jetty.util.StaticException; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -195,6 +196,7 @@ public void cancel(LastWill lastWill) private static final class ActiveSubscription extends IteratingCallback implements LastWillSubscription { private static final long NO_MORE_DEMAND = -1; + private static final Throwable COMPLETED = new StaticException("Source.Content read fully"); private final AtomicReference cancelled; private final AtomicLong demand; private Content.Source content; @@ -275,7 +277,7 @@ protected Action process() if (chunk.isLast()) { - cancel(new CompletionException("Source.Content read fully", null), FinalSignal.COMPLETE); + cancel(COMPLETED, FinalSignal.COMPLETE); return Action.IDLE; }