Implements missing methods
This commit is contained in:
@@ -136,6 +136,11 @@ public class DefaultClientResponse implements ClientResponse {
|
||||
throw new UnsupportedOperationException();
|
||||
}
|
||||
|
||||
@Override
|
||||
public String logPrefix() {
|
||||
return "";
|
||||
}
|
||||
|
||||
@SuppressWarnings("unchecked")
|
||||
private <T> Mono<T> consumeAndCancel() {
|
||||
return (Mono<T>) this.response.getBody().map(buffer -> {
|
||||
|
||||
@@ -127,7 +127,12 @@ public class DefaultServerRequest implements ServerRequest {
|
||||
|
||||
@Override
|
||||
public Optional<InetSocketAddress> remoteAddress() {
|
||||
return Optional.of(request().getRemoteAddress());
|
||||
return Optional.ofNullable(request().getRemoteAddress());
|
||||
}
|
||||
|
||||
@Override
|
||||
public Optional<InetSocketAddress> localAddress() {
|
||||
return Optional.ofNullable(request().getLocalAddress());
|
||||
}
|
||||
|
||||
@Override
|
||||
|
||||
Reference in New Issue
Block a user