Changed addBody() to setBody()

spring-web-reactive/src/main/java/org/springframework/http/ReactiveHttpOutputMessage.java

@@ -22,7 +22,7 @@ import org.reactivestreams.Publisher;
 
 /**
  * Represents a "reactive" HTTP output message, consisting of {@linkplain #getHeaders() headers}
- * and the capability to add a {@linkplain #addBody(Publisher) body}.
+ * and the capability to add a {@linkplain #setBody(Publisher) body}.
  *
  * <p>Typically implemented by an HTTP request on the client-side, or a response on the server-side.
  *
@@ -36,6 +36,6 @@ public interface ReactiveHttpOutputMessage extends HttpMessage {
 	 * @param body the body to add
 	 * @return a publisher that indicates completion
 	 */
-	Publisher<Void> addBody(Publisher<ByteBuffer> body);
+	Publisher<Void> setBody(Publisher<ByteBuffer> body);
 
 }

spring-web-reactive/src/main/java/org/springframework/reactive/web/dispatch/method/annotation/ResponseBodyResultHandler.java

@@ -140,10 +140,11 @@ public class ResponseBodyResultHandler implements HandlerResultHandler, Ordered
 				outputStream = postProcessor.encode(outputStream, elementType, mediaType, hints.toArray());
 			}
 			response.getHeaders().setContentType(mediaType);
-			return response.addBody(outputStream);
+			return response.setBody(outputStream);
 		}
 		return Publishers.error(new IllegalStateException(
-		  "Return value type '" + returnType.getParameterType().getName() + "' with media type '" + mediaType + "' not supported"  ));
+				"Return value type '" + returnType.getParameterType().getName() +
+						"' with media type '" + mediaType + "' not supported"));
 	}
 
 	private MediaType resolveMediaType(ReactiveServerHttpRequest request) {

spring-web-reactive/src/main/java/org/springframework/reactive/web/http/HttpHandler.java

@@ -31,7 +31,7 @@ import org.springframework.http.server.ReactiveServerHttpResponse;
  * @author Rossen Stoyanchev
  * @author Sebastien Deleuze
  * @see ReactiveServerHttpRequest#getBody()
- * @see ReactiveServerHttpResponse#addBody(Publisher)
+ * @see ReactiveServerHttpResponse#setBody(Publisher)
  */
 public interface HttpHandler {
 

spring-web-reactive/src/main/java/org/springframework/reactive/web/http/reactor/PublisherReactorServerHttpResponse.java

@@ -67,7 +67,7 @@ public class PublisherReactorServerHttpResponse implements ReactiveServerHttpRes
 	}
 
 	@Override
-	public Publisher<Void> addBody(Publisher<ByteBuffer> contentPublisher) {
+	public Publisher<Void> setBody(Publisher<ByteBuffer> contentPublisher) {
 		applyHeaders();
 		return this.channel.writeWith(Publishers.map(contentPublisher, Buffer::new));
 	}

spring-web-reactive/src/main/java/org/springframework/reactive/web/http/reactor/ReactorServerHttpResponse.java

@@ -38,7 +38,7 @@ public class ReactorServerHttpResponse extends PublisherReactorServerHttpRespons
 	}
 
 	@Override
-	public Stream<Void> addBody(Publisher<ByteBuffer> contentPublisher) {
+	public Stream<Void> setBody(Publisher<ByteBuffer> contentPublisher) {
-		return Streams.wrap(super.addBody(contentPublisher));
+		return Streams.wrap(super.setBody(contentPublisher));
 	}
 }

spring-web-reactive/src/main/java/org/springframework/reactive/web/http/rxnetty/RxNettyServerHttpResponse.java

@@ -75,7 +75,7 @@ public class RxNettyServerHttpResponse implements ReactiveServerHttpResponse {
 	}
 
 	@Override
-	public Publisher<Void> addBody(Publisher<ByteBuffer> contentPublisher) {
+	public Publisher<Void> setBody(Publisher<ByteBuffer> contentPublisher) {
 		applyHeaders();
 		Observable<byte[]> contentObservable = RxJava1Converter.from(contentPublisher).map(content -> new Buffer(content).asBytes());
 		return RxJava1Converter.from(this.response.writeBytes(contentObservable));

spring-web-reactive/src/main/java/org/springframework/reactive/web/http/servlet/ServletServerHttpResponse.java

@@ -69,7 +69,7 @@ public class ServletServerHttpResponse implements ReactiveServerHttpResponse {
 	}
 
 	@Override
-	public Publisher<Void> addBody(final Publisher<ByteBuffer> contentPublisher) {
+	public Publisher<Void> setBody(final Publisher<ByteBuffer> contentPublisher) {
 		applyHeaders();
 		return (s -> contentPublisher.subscribe(responseSubscriber));
 	}

spring-web-reactive/src/test/java/org/springframework/reactive/web/dispatch/handler/SimpleUrlHandlerMappingIntegrationTests.java

@@ -101,7 +101,7 @@ public class SimpleUrlHandlerMappingIntegrationTests extends AbstractHttpHandler
 
 		@Override
 		public Publisher<Void> handle(ReactiveServerHttpRequest request, ReactiveServerHttpResponse response) {
-			return response.addBody(Streams.just(Buffer.wrap("foo").byteBuffer()));
+			return response.setBody(Streams.just(Buffer.wrap("foo").byteBuffer()));
 		}
 	}
 
@@ -109,7 +109,7 @@ public class SimpleUrlHandlerMappingIntegrationTests extends AbstractHttpHandler
 
 		@Override
 		public Publisher<Void> handle(ReactiveServerHttpRequest request, ReactiveServerHttpResponse response) {
-			return response.addBody(Streams.just(Buffer.wrap("bar").byteBuffer()));
+			return response.setBody(Streams.just(Buffer.wrap("bar").byteBuffer()));
 		}
 	}
 

spring-web-reactive/src/test/java/org/springframework/reactive/web/http/EchoHandler.java

@@ -28,6 +28,6 @@ public class EchoHandler implements HttpHandler {
 
 	@Override
 	public Publisher<Void> handle(ReactiveServerHttpRequest request, ReactiveServerHttpResponse response) {
-		return response.addBody(request.getBody());
+		return response.setBody(request.getBody());
 	}
 }

spring-web-reactive/src/test/java/org/springframework/reactive/web/http/RandomHandler.java

@@ -76,7 +76,7 @@ public class RandomHandler implements HttpHandler {
 		});
 
 		response.getHeaders().setContentLength(RESPONSE_SIZE);
-		return response.addBody(Streams.just(ByteBuffer.wrap(randomBytes())));
+		return response.setBody(Streams.just(ByteBuffer.wrap(randomBytes())));
 	}
 
 	private byte[] randomBytes() {

spring-web-reactive/src/test/java/org/springframework/reactive/web/http/XmlHandler.java

@@ -75,7 +75,7 @@ public class XmlHandler implements HttpHandler {
 			bos.close();
 			buffer.flip();
 
-			return response.addBody(Streams.just(buffer.byteBuffer()));
+			return response.setBody(Streams.just(buffer.byteBuffer()));
 		}
 		catch (Exception ex) {
 			logger.error(ex, ex);