Spring/spring-framework
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Polishing

Browse Source
This commit is contained in:
Brian Clozel
2024-12-03 15:59:12 +01:00
parent 5de03f6bb1
commit 342369355d
3 changed files with 7 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
spring-web/src/main/java/org/springframework/http/server/reactive/ServletHttpHandlerAdapter.java
View File

@@ -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

10
spring-web/src/main/java/org/springframework/http/server/reactive/ServletServerHttpResponse.java
View File

@@ -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();

6
spring-web/src/main/java/org/springframework/http/server/reactive/TomcatHttpHandlerAdapter.java
View File

@@ -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) {