提交 dff9b3b8 编写于 作者: A Arjen Poutsma

Expose BodyInserter in EntityResponse

上级 44ec6e00
...@@ -196,6 +196,11 @@ class DefaultEntityResponseBuilder<T> implements EntityResponse.Builder<T> { ...@@ -196,6 +196,11 @@ class DefaultEntityResponseBuilder<T> implements EntityResponse.Builder<T> {
return this.entity; return this.entity;
} }
@Override
public BodyInserter<T, ? super ServerHttpResponse> inserter() {
return this.inserter;
}
@Override @Override
public Mono<Void> writeTo(ServerWebExchange exchange, HandlerStrategies strategies) { public Mono<Void> writeTo(ServerWebExchange exchange, HandlerStrategies strategies) {
ServerHttpResponse response = exchange.getResponse(); ServerHttpResponse response = exchange.getResponse();
......
...@@ -30,6 +30,8 @@ import org.springframework.http.HttpMethod; ...@@ -30,6 +30,8 @@ import org.springframework.http.HttpMethod;
import org.springframework.http.HttpStatus; import org.springframework.http.HttpStatus;
import org.springframework.http.MediaType; import org.springframework.http.MediaType;
import org.springframework.http.codec.json.AbstractJackson2Codec; import org.springframework.http.codec.json.AbstractJackson2Codec;
import org.springframework.http.server.reactive.ServerHttpResponse;
import org.springframework.web.reactive.function.BodyInserter;
import org.springframework.web.reactive.function.BodyInserters; import org.springframework.web.reactive.function.BodyInserters;
/** /**
...@@ -45,6 +47,11 @@ public interface EntityResponse<T> extends ServerResponse { ...@@ -45,6 +47,11 @@ public interface EntityResponse<T> extends ServerResponse {
*/ */
T entity(); T entity();
/**
* Return the {@code BodyInserter} that writes the entity to the output stream.
*/
BodyInserter<T, ? super ServerHttpResponse> inserter();
// Static builder methods // Static builder methods
/** /**
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册