Create on demand the response object for "Expect: 100-continue" (#3362)

reactor-netty-http/src/main/java/reactor/netty/http/server/HttpServerOperations.java

@@ -1,5 +1,5 @@
 /*
- * Copyright (c) 2011-2023 VMware, Inc. or its affiliates, All Rights Reserved.
+ * Copyright (c) 2011-2024 VMware, Inc. or its affiliates, All Rights Reserved.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -45,7 +45,6 @@
 import io.netty.handler.codec.http.DefaultHttpResponse;
 import io.netty.handler.codec.http.DefaultLastHttpContent;
 import io.netty.handler.codec.http.FullHttpRequest;
-import io.netty.handler.codec.http.FullHttpResponse;
 import io.netty.handler.codec.http.HttpContent;
 import io.netty.handler.codec.http.HttpHeaderNames;
 import io.netty.handler.codec.http.HttpHeaderValues;
@@ -411,13 +410,13 @@ public Flux<?> receiveObject() {
 		//       If decoding a response, just throw an error.
 		if (is100ContinueExpected) {
 			return FutureMono.deferFuture(() -> {
-						if (!hasSentHeaders()) {
-							return channel().writeAndFlush(CONTINUE);
-						}
-						return channel().newSucceededFuture();
-					})
-
-			                 .thenMany(super.receiveObject());
+				if (!hasSentHeaders()) {
+					return channel().writeAndFlush(
+							new DefaultFullHttpResponse(HttpVersion.HTTP_1_1, HttpResponseStatus.CONTINUE, EMPTY_BUFFER));
+				}
+				return channel().newSucceededFuture();
+			})
+					.thenMany(super.receiveObject());
 		}
 		else {
 			return super.receiveObject();
@@ -1009,11 +1008,6 @@ public Context currentContext() {
 
 	static final BiPredicate<HttpServerRequest, HttpServerResponse> COMPRESSION_DISABLED = (req, res) -> false;
 
-	static final FullHttpResponse CONTINUE     =
-			new DefaultFullHttpResponse(HttpVersion.HTTP_1_1,
-					HttpResponseStatus.CONTINUE,
-					EMPTY_BUFFER);
-
 	static final class FailedHttpServerRequest extends HttpServerOperations {
 
 		final HttpResponse customResponse;