From ad9d8c28fee58d9ae25de6689ab9d31238f18337 Mon Sep 17 00:00:00 2001
From: Stephane Maldini <smaldini@pivotal.io>
Date: Sun, 17 Apr 2016 14:50:20 +0100
Subject: [PATCH] Polish reactor-ipc/netty contracts

---
 .../http/client/reactive/ReactorClientHttpRequest.java          | 2 +-
 .../http/client/reactive/ReactorClientHttpResponse.java         | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/spring-web-reactive/src/main/java/org/springframework/http/client/reactive/ReactorClientHttpRequest.java b/spring-web-reactive/src/main/java/org/springframework/http/client/reactive/ReactorClientHttpRequest.java
index fc589a1463..16a192a5bc 100644
--- a/spring-web-reactive/src/main/java/org/springframework/http/client/reactive/ReactorClientHttpRequest.java
+++ b/spring-web-reactive/src/main/java/org/springframework/http/client/reactive/ReactorClientHttpRequest.java
@@ -111,7 +111,7 @@ public class ReactorClientHttpRequest extends AbstractClientHttpRequest {
 							})
 							.after(() -> {
 								if (body != null) {
-									return channel.sendBody(body);
+									return channel.send(body);
 								}
 								else {
 									return channel.sendHeaders();
diff --git a/spring-web-reactive/src/main/java/org/springframework/http/client/reactive/ReactorClientHttpResponse.java b/spring-web-reactive/src/main/java/org/springframework/http/client/reactive/ReactorClientHttpResponse.java
index c45181c699..9b3757caf2 100644
--- a/spring-web-reactive/src/main/java/org/springframework/http/client/reactive/ReactorClientHttpResponse.java
+++ b/spring-web-reactive/src/main/java/org/springframework/http/client/reactive/ReactorClientHttpResponse.java
@@ -50,7 +50,7 @@ public class ReactorClientHttpResponse implements ClientHttpResponse {
 
 	@Override
 	public Flux<DataBuffer> getBody() {
-		return channel.receiveBody().map(b -> allocator.wrap(b.byteBuffer()));
+		return channel.receive().map(b -> allocator.wrap(b.byteBuffer()));
 	}
 
 	@Override