Polish reactor-ipc/netty contracts
This commit is contained in:
parent
0a3396c5b2
commit
ad9d8c28fe
|
@ -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();
|
||||
|
|
|
@ -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
|
||||
|
|
Loading…
Reference in New Issue