The asynch Web client by default emits Mono.empty() when there is no body,
now an empty string is returned instead.
Change-Id: I8963a93bd41c7654cddd9e01700883d472c0d3f0
Issue-ID: NONRTRIC-107
Signed-off-by: PatrikBuhr <patrik.buhr@est.tech>
.retrieve() //
.onStatus(HttpStatus::isError,
response -> Mono.error(new AsyncRestClientException(response.statusCode().toString()))) //
.retrieve() //
.onStatus(HttpStatus::isError,
response -> Mono.error(new AsyncRestClientException(response.statusCode().toString()))) //
- .bodyToMono(String.class);
+ .bodyToMono(String.class) //
+ .defaultIfEmpty("");
}
public Mono<String> postWithAuthHeader(String uri, String body, String username, String password) {
}
public Mono<String> postWithAuthHeader(String uri, String body, String username, String password) {
.retrieve() //
.onStatus(HttpStatus::isError,
response -> Mono.error(new AsyncRestClientException(response.statusCode().toString()))) //
.retrieve() //
.onStatus(HttpStatus::isError,
response -> Mono.error(new AsyncRestClientException(response.statusCode().toString()))) //
- .bodyToMono(String.class);
+ .bodyToMono(String.class) //
+ .defaultIfEmpty("");
}
public Mono<String> put(String uri, String body) {
}
public Mono<String> put(String uri, String body) {
.retrieve() //
.onStatus(HttpStatus::isError,
response -> Mono.error(new AsyncRestClientException(response.statusCode().toString()))) //
.retrieve() //
.onStatus(HttpStatus::isError,
response -> Mono.error(new AsyncRestClientException(response.statusCode().toString()))) //
- .bodyToMono(String.class);
+ .bodyToMono(String.class) //
+ .defaultIfEmpty("");
}
public Mono<String> get(String uri) {
}
public Mono<String> get(String uri) {
.retrieve() //
.onStatus(HttpStatus::isError,
response -> Mono.error(new AsyncRestClientException(response.statusCode().toString()))) //
.retrieve() //
.onStatus(HttpStatus::isError,
response -> Mono.error(new AsyncRestClientException(response.statusCode().toString()))) //
- .bodyToMono(String.class);
+ .bodyToMono(String.class) //
+ .defaultIfEmpty("");
}
public Mono<String> delete(String uri) {
}
public Mono<String> delete(String uri) {
.retrieve() //
.onStatus(HttpStatus::isError,
response -> Mono.error(new AsyncRestClientException(response.statusCode().toString()))) //
.retrieve() //
.onStatus(HttpStatus::isError,
response -> Mono.error(new AsyncRestClientException(response.statusCode().toString()))) //
- .bodyToMono(String.class);
+ .bodyToMono(String.class) //
+ .defaultIfEmpty("");
mockWebServer.enqueue(new MockResponse().setResponseCode(SUCCESS_CODE));
Mono<String> returnedMono = clientUnderTest.delete(REQUEST_URL);
mockWebServer.enqueue(new MockResponse().setResponseCode(SUCCESS_CODE));
Mono<String> returnedMono = clientUnderTest.delete(REQUEST_URL);
- StepVerifier.create(returnedMono).expectComplete().verify();
+ StepVerifier.create(returnedMono).expectNext("").expectComplete().verify();