* added support for streaming response modification

Fixes spring-cloudgh-2275

Author: usrivastava92

pom.xml

@@ -143,7 +143,6 @@
 			<plugin>
 				<groupId>org.codehaus.mojo</groupId>
 				<artifactId>flatten-maven-plugin</artifactId>
-				<version>1.3.0</version>
 			</plugin>
 			<plugin>
 				<groupId>io.spring.javaformat</groupId>

spring-cloud-gateway-server/src/main/java/org/springframework/cloud/gateway/filter/factory/rewrite/ModifyResponseBodyGatewayFilterFactory.java

@@ -287,13 +287,11 @@ public Mono<Void> writeWith(Publisher<? extends DataBuffer> body) {
 					exchange.getResponse().getHeaders());
 			return bodyInserter.insert(outputMessage, new BodyInserterContext())
 					.then(Mono.defer(() -> {
-						Mono<DataBuffer> messageBody = writeBody(getDelegate(),
-								outputMessage, outClass);
+						Mono<DataBuffer> messageBody = writeBody(getDelegate(), outputMessage, outClass);
 						HttpHeaders headers = getDelegate().getHeaders();
 						if (!headers.containsKey(HttpHeaders.TRANSFER_ENCODING)
 								|| headers.containsKey(HttpHeaders.CONTENT_LENGTH)) {
-							messageBody = messageBody.doOnNext(data -> headers
-									.setContentLength(data.readableByteCount()));
+							messageBody = messageBody.doOnNext(data -> headers.setContentLength(data.readableByteCount()));
 						}
 
 						if (StringUtils.hasText(config.newContentType)) {