|
|
|
|
@ -44,7 +44,7 @@ import org.springframework.http.support.JettyHeadersAdapter;
@@ -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
@@ -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
@@ -77,6 +78,7 @@ class JettyCoreServerHttpResponse extends AbstractServerHttpResponse implements
|
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
|
protected Mono<Void> writeWithInternal(Publisher<? extends DataBuffer> body) { |
|
|
|
|
return Flux.from(body) |
|
|
|
|
@ -158,16 +160,16 @@ class JettyCoreServerHttpResponse extends AbstractServerHttpResponse implements
@@ -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
@@ -233,5 +235,7 @@ class JettyCoreServerHttpResponse extends AbstractServerHttpResponse implements
|
|
|
|
|
public Map<String, String> getAttributes() { |
|
|
|
|
return Collections.emptyMap(); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
} |
|
|
|
|
|