iSharkFly-Docs
/
java-tutorials
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

BAEL-5054 fix indentations

This commit is contained in:
Trixi Turny 2021-09-05 12:55:26 +02:00
parent 82c3389ba0
commit 439848c165
2 changed files with 16 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
spring-5-reactive-client/src/main/java/com/baeldung/reactive/service/ReactiveUploadService.java
View File

@ -34,11 +34,11 @@ public class ReactiveUploadService {
.contentType(MediaType.APPLICATION_PDF)
.body(BodyInserters.fromResource(resource))
.exchangeToMono(response -> {
if (response.statusCode().equals(HttpStatus.OK)) {
return response.bodyToMono(HttpStatus.class).thenReturn(response.statusCode());
} else {
throw new ServiceException("Error uploading file");
}
if (response.statusCode().equals(HttpStatus.OK)) {
return response.bodyToMono(HttpStatus.class).thenReturn(response.statusCode());
} else {
throw new ServiceException("Error uploading file");
}
});
return httpStatusMono;
}
@ -55,11 +55,11 @@ public class ReactiveUploadService {
.contentType(MediaType.MULTIPART_FORM_DATA)
.body(BodyInserters.fromMultipartData(builder.build()))
.exchangeToMono(response -> {
if (response.statusCode().equals(HttpStatus.OK)) {
return response.bodyToMono(HttpStatus.class).thenReturn(response.statusCode());
} else {
throw new ServiceException("Error uploading file");
}
if (response.statusCode().equals(HttpStatus.OK)) {
return response.bodyToMono(HttpStatus.class).thenReturn(response.statusCode());
} else {
throw new ServiceException("Error uploading file");
}
});
return httpStatusMono;
}

8
spring-5-reactive-client/src/test/java/com/baeldung/reactive/service/ReactiveUploadServiceUnitTest.java
View File

@ -18,8 +18,8 @@ class ReactiveUploadServiceUnitTest {
final WebClient webClientMock = WebClient.builder().baseUrl(BASE_URL)
.exchangeFunction(clientRequest -> Mono.just(ClientResponse.create(HttpStatus.OK)
.header("content-type", "application/json")
.build()))
.header("content-type", "application/json")
.build()))
.build();
private final ReactiveUploadService tested = new ReactiveUploadService(webClientMock);
@ -27,8 +27,10 @@ class ReactiveUploadServiceUnitTest {
@Test
void givenAPdf_whenUploadingWithWebClient_thenOK() {
final Resource file = mock(Resource.class);
final Mono<HttpStatus> result = tested.uploadPdf(file);
final HttpStatus status = result.block();
assertThat(status).isEqualTo(HttpStatus.OK);
}
@ -37,8 +39,10 @@ class ReactiveUploadServiceUnitTest {
final Resource file = mock(Resource.class);
final MultipartFile multipartFile = mock(MultipartFile.class);
when(multipartFile.getResource()).thenReturn(file);
final Mono<HttpStatus> result = tested.uploadMultipart(multipartFile);
final HttpStatus status = result.block();
assertThat(status).isEqualTo(HttpStatus.OK);
}
}