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

made tests assertions non-blocking

This commit is contained in:
Gerardo Roza 2021-01-25 12:26:37 -03:00
parent a37812ce04
commit 615322468e
2 changed files with 45 additions and 34 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
spring-5-reactive/pom.xml
View File

@ -1,6 +1,7 @@
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<artifactId>spring-5-reactive</artifactId>
<version>0.0.1-SNAPSHOT</version>
@ -73,6 +74,12 @@
<artifactId>spring-security-test</artifactId>
<scope>test</scope>
</dependency>
<dependency>
<groupId>io.projectreactor</groupId>
<artifactId>reactor-test</artifactId>
<scope>test</scope>
</dependency>
<!-- Spring WebFlux WebSession -->
<dependency>

68
spring-5-reactive/src/test/java/com/baeldung/web/client/WebClientIntegrationTest.java
View File

@ -46,6 +46,7 @@ import io.netty.handler.timeout.ReadTimeoutHandler;
import io.netty.handler.timeout.WriteTimeoutHandler;
import reactor.core.publisher.Mono;
import reactor.netty.http.client.HttpClient;
import reactor.test.StepVerifier;
@SpringBootTest(classes = WebClientApplication.class, webEnvironment = WebEnvironment.RANDOM_PORT)
public class WebClientIntegrationTest {
@ -107,44 +108,46 @@ public class WebClientIntegrationTest {
// request
ResponseSpec responseSpecPostString = headerSpecInserterStringWithHeaders.retrieve();
String responsePostString = responseSpecPostString.bodyToMono(String.class)
.block();
String responsePostMultipart = headerSpecInserterMultipart.header(HttpHeaders.CONTENT_TYPE, MediaType.MULTIPART_FORM_DATA_VALUE)
Mono<String> responsePostString = responseSpecPostString.bodyToMono(String.class);
Mono<String> responsePostMultipart = headerSpecInserterMultipart.header(HttpHeaders.CONTENT_TYPE, MediaType.MULTIPART_FORM_DATA_VALUE)
.retrieve()
.bodyToMono(String.class)
.block();
String responsePostWithBody1 = headerSpecPost1.retrieve()
.bodyToMono(String.class)
.block();
String responsePostWithBody2 = headerSpecPost2.retrieve()
.bodyToMono(String.class)
.block();
String responsePostWithBody3 = headerSpecPost2.retrieve()
.bodyToMono(String.class)
.block();
String responsePostFoo = headerSpecFooPost.retrieve()
.bodyToMono(String.class)
.block();
.bodyToMono(String.class);
Mono<String> responsePostWithBody1 = headerSpecPost1.retrieve()
.bodyToMono(String.class);
Mono<String> responsePostWithBody2 = headerSpecPost2.retrieve()
.bodyToMono(String.class);
Mono<String> responsePostWithBody3 = headerSpecPost2.retrieve()
.bodyToMono(String.class);
Mono<String> responsePostFoo = headerSpecFooPost.retrieve()
.bodyToMono(String.class);
ParameterizedTypeReference<Map<String, String>> ref = new ParameterizedTypeReference<Map<String, String>>() {
};
Map<String, String> responseGet = headerSpecGet.retrieve()
.bodyToMono(ref)
.block();
Map<String, String> responsePostWithNoBody = createDefaultPostResourceRequest().exchangeToMono(responseHandler -> {
Mono<Map<String, String>> responseGet = headerSpecGet.retrieve()
.bodyToMono(ref);
Mono<Map<String, String>> responsePostWithNoBody = createDefaultPostResourceRequest().exchangeToMono(responseHandler -> {
assertThat(responseHandler.statusCode()).isEqualTo(HttpStatus.BAD_REQUEST);
return responseHandler.bodyToMono(ref);
})
.block();
});
// response assertions
assertThat(responsePostString).isEqualTo("processed-bodyValue");
assertThat(responsePostMultipart).isEqualTo("processed-multipartValue1-multipartValue2");
assertThat(responsePostWithBody1).isEqualTo("processed-bodyValue");
assertThat(responsePostWithBody2).isEqualTo("processed-bodyValue");
assertThat(responsePostWithBody3).isEqualTo("processed-bodyValue");
assertThat(responseGet).containsEntry("field", "value");
assertThat(responsePostFoo).isEqualTo("processedFoo-fooName");
assertThat(responsePostWithNoBody).containsEntry("error", "Bad Request");
StepVerifier.create(responsePostString)
.expectNext("processed-bodyValue");
StepVerifier.create(responsePostMultipart)
.expectNext("processed-multipartValue1-multipartValue2");
StepVerifier.create(responsePostWithBody1)
.expectNext("processed-bodyValue");
StepVerifier.create(responsePostWithBody2)
.expectNext("processed-bodyValue");
StepVerifier.create(responsePostWithBody3)
.expectNext("processed-bodyValue");
StepVerifier.create(responseGet)
.expectNextMatches(nextMap -> nextMap.get("field")
.equals("value"));
StepVerifier.create(responsePostFoo)
.expectNext("processedFoo-fooName");
StepVerifier.create(responsePostWithNoBody)
.expectNextMatches(nextMap -> nextMap.get("error")
.equals("Bad Request"));
// assert sending plain `new Object()` as request body
assertThrows(CodecException.class, () -> {
@ -152,11 +155,12 @@ public class WebClientIntegrationTest {
.block();
});
// assert sending request overriding base uri
assertThrows(WebClientRequestException.class, () -> {
Exception exception = assertThrows(WebClientRequestException.class, () -> {
bodySpecOverridenBaseUri.retrieve()
.bodyToMono(String.class)
.block();
});
assertThat(exception.getMessage()).contains("Connection refused");
}