diff --git a/spring-webflux/src/main/java/org/springframework/web/reactive/function/server/DefaultEntityResponseBuilder.java b/spring-webflux/src/main/java/org/springframework/web/reactive/function/server/DefaultEntityResponseBuilder.java index 7670319eaac..4fe1e29fbbf 100644 --- a/spring-webflux/src/main/java/org/springframework/web/reactive/function/server/DefaultEntityResponseBuilder.java +++ b/spring-webflux/src/main/java/org/springframework/web/reactive/function/server/DefaultEntityResponseBuilder.java @@ -196,6 +196,11 @@ class DefaultEntityResponseBuilder implements EntityResponse.Builder { return this.entity; } + @Override + public BodyInserter inserter() { + return this.inserter; + } + @Override public Mono writeTo(ServerWebExchange exchange, HandlerStrategies strategies) { ServerHttpResponse response = exchange.getResponse(); diff --git a/spring-webflux/src/main/java/org/springframework/web/reactive/function/server/EntityResponse.java b/spring-webflux/src/main/java/org/springframework/web/reactive/function/server/EntityResponse.java index 4a3c2dc1f1c..27a891a09fc 100644 --- a/spring-webflux/src/main/java/org/springframework/web/reactive/function/server/EntityResponse.java +++ b/spring-webflux/src/main/java/org/springframework/web/reactive/function/server/EntityResponse.java @@ -30,6 +30,8 @@ import org.springframework.http.HttpMethod; import org.springframework.http.HttpStatus; import org.springframework.http.MediaType; 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; /** @@ -45,6 +47,11 @@ public interface EntityResponse extends ServerResponse { */ T entity(); + /** + * Return the {@code BodyInserter} that writes the entity to the output stream. + */ + BodyInserter inserter(); + // Static builder methods /**