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 getBody() { - return channel.receiveBody().map(b -> allocator.wrap(b.byteBuffer())); + return channel.receive().map(b -> allocator.wrap(b.byteBuffer())); } @Override