diff --git a/spring-web/src/main/java/org/springframework/http/server/reactive/ServletHttpHandlerAdapter.java b/spring-web/src/main/java/org/springframework/http/server/reactive/ServletHttpHandlerAdapter.java index 093076710b..e16a4b6287 100644 --- a/spring-web/src/main/java/org/springframework/http/server/reactive/ServletHttpHandlerAdapter.java +++ b/spring-web/src/main/java/org/springframework/http/server/reactive/ServletHttpHandlerAdapter.java @@ -210,7 +210,7 @@ public class ServletHttpHandlerAdapter implements Servlet { protected ServletServerHttpResponse createResponse(HttpServletResponse response, AsyncContext context, ServletServerHttpRequest request) throws IOException { - return new ServletServerHttpResponse(response, context, getDataBufferFactory(), getBufferSize(), request); + return new ServletServerHttpResponse(response, context, getDataBufferFactory(), request); } @Override diff --git a/spring-web/src/main/java/org/springframework/http/server/reactive/ServletServerHttpResponse.java b/spring-web/src/main/java/org/springframework/http/server/reactive/ServletServerHttpResponse.java index ac145a04d4..ccaf9b5733 100644 --- a/spring-web/src/main/java/org/springframework/http/server/reactive/ServletServerHttpResponse.java +++ b/spring-web/src/main/java/org/springframework/http/server/reactive/ServletServerHttpResponse.java @@ -54,8 +54,6 @@ class ServletServerHttpResponse extends AbstractListenerServerHttpResponse { private final ServletOutputStream outputStream; - private final int bufferSize; - @Nullable private volatile ResponseBodyFlushProcessor bodyFlushProcessor; @@ -70,23 +68,21 @@ class ServletServerHttpResponse extends AbstractListenerServerHttpResponse { public ServletServerHttpResponse(HttpServletResponse response, AsyncContext asyncContext, - DataBufferFactory bufferFactory, int bufferSize, ServletServerHttpRequest request) throws IOException { + DataBufferFactory bufferFactory, ServletServerHttpRequest request) throws IOException { - this(new HttpHeaders(), response, asyncContext, bufferFactory, bufferSize, request); + this(new HttpHeaders(), response, asyncContext, bufferFactory, request); } public ServletServerHttpResponse(HttpHeaders headers, HttpServletResponse response, AsyncContext asyncContext, - DataBufferFactory bufferFactory, int bufferSize, ServletServerHttpRequest request) throws IOException { + DataBufferFactory bufferFactory, ServletServerHttpRequest request) throws IOException { super(bufferFactory, headers); Assert.notNull(response, "HttpServletResponse must not be null"); Assert.notNull(bufferFactory, "DataBufferFactory must not be null"); - Assert.isTrue(bufferSize > 0, "Buffer size must be greater than 0"); this.response = response; this.outputStream = response.getOutputStream(); - this.bufferSize = bufferSize; this.request = request; this.asyncListener = new ResponseAsyncListener(); diff --git a/spring-web/src/main/java/org/springframework/http/server/reactive/TomcatHttpHandlerAdapter.java b/spring-web/src/main/java/org/springframework/http/server/reactive/TomcatHttpHandlerAdapter.java index 20064837c7..aaae97ba03 100644 --- a/spring-web/src/main/java/org/springframework/http/server/reactive/TomcatHttpHandlerAdapter.java +++ b/spring-web/src/main/java/org/springframework/http/server/reactive/TomcatHttpHandlerAdapter.java @@ -69,7 +69,7 @@ public class TomcatHttpHandlerAdapter extends ServletHttpHandlerAdapter { AsyncContext asyncContext, ServletServerHttpRequest request) throws IOException { return new TomcatServerHttpResponse( - response, asyncContext, getDataBufferFactory(), getBufferSize(), request); + response, asyncContext, getDataBufferFactory(), request); } @@ -129,9 +129,9 @@ public class TomcatHttpHandlerAdapter extends ServletHttpHandlerAdapter { } TomcatServerHttpResponse(HttpServletResponse response, AsyncContext context, - DataBufferFactory factory, int bufferSize, ServletServerHttpRequest request) throws IOException { + DataBufferFactory factory, ServletServerHttpRequest request) throws IOException { - super(createTomcatHttpHeaders(response), response, context, factory, bufferSize, request); + super(createTomcatHttpHeaders(response), response, context, factory, request); } private static HttpHeaders createTomcatHttpHeaders(HttpServletResponse response) {