diff --git a/spring-web/src/main/java/org/springframework/http/server/reactive/JettyCoreServerHttpResponse.java b/spring-web/src/main/java/org/springframework/http/server/reactive/JettyCoreServerHttpResponse.java index fbf533ec056..a53cab42190 100644 --- a/spring-web/src/main/java/org/springframework/http/server/reactive/JettyCoreServerHttpResponse.java +++ b/spring-web/src/main/java/org/springframework/http/server/reactive/JettyCoreServerHttpResponse.java @@ -44,7 +44,7 @@ import org.springframework.http.support.JettyHeadersAdapter; import org.springframework.lang.Nullable; /** - * Adapt an Eclipse Jetty {@link Response} to a {@link org.springframework.http.server.ServerHttpResponse}. + * Adapt an Eclipse Jetty {@link Response} to an {@link org.springframework.http.server.ServerHttpResponse}. * * @author Greg Wilkins * @author Lachlan Roberts @@ -54,6 +54,7 @@ class JettyCoreServerHttpResponse extends AbstractServerHttpResponse implements private final Response response; + public JettyCoreServerHttpResponse(Response response, JettyDataBufferFactory dataBufferFactory) { super(dataBufferFactory, new HttpHeaders(new JettyHeadersAdapter(response.getHeaders()))); this.response = response; @@ -77,6 +78,7 @@ class JettyCoreServerHttpResponse extends AbstractServerHttpResponse implements } } + @Override protected Mono writeWithInternal(Publisher body) { return Flux.from(body) @@ -158,16 +160,16 @@ class JettyCoreServerHttpResponse extends AbstractServerHttpResponse implements return (T) this.response; } + private static class ResponseHttpCookie implements org.eclipse.jetty.http.HttpCookie { + private final ResponseCookie responseCookie; - public ResponseHttpCookie(ResponseCookie responseCookie) { + + ResponseHttpCookie(ResponseCookie responseCookie) { this.responseCookie = responseCookie; } - public ResponseCookie getResponseCookie() { - return this.responseCookie; - } @Override public String getName() { @@ -233,5 +235,7 @@ class JettyCoreServerHttpResponse extends AbstractServerHttpResponse implements public Map getAttributes() { return Collections.emptyMap(); } + } + }