+ @Test
+ public void testNoError()
+ {
+ Mono<String> result;
+
+
+ server
+ .enqueue(new MockResponse()
+ .setResponseCode(HttpStatus.CONTINUE.value())
+ .setHeader("Content-Type", "application/json")
+ .setBody("Hallo Welt!"));
+
+ result =
+ webClient
+ .get()
+ .uri("/egal")
+ .retrieve()
+ .bodyToMono(String.class);
+
+ StepVerifier
+ .create(result)
+ .expectNext("Hallo Welt!")
+ .expectComplete()
+ .verify();
+
+
+ server
+ .enqueue(new MockResponse()
+ .setResponseCode(HttpStatus.OK.value())
+ .setHeader("Content-Type", "text/plain")
+ .setBody("Hallo Welt!"));
+
+ result =
+ webClient
+ .get()
+ .uri("/egal")
+ .retrieve()
+ .bodyToMono(String.class);
+
+ StepVerifier
+ .create(result)
+ .expectNext("Hallo Welt!")
+ .expectComplete()
+ .verify();
+
+
+ server
+ .enqueue(new MockResponse()
+ .setResponseCode(HttpStatus.TEMPORARY_REDIRECT.value())
+ .setHeader("Content-Type", "text/plain")
+ .setBody("Hallo Welt!"));
+
+ result =
+ webClient
+ .get()
+ .uri("/egal")
+ .retrieve()
+ .bodyToMono(String.class);
+
+ StepVerifier
+ .create(result)
+ .expectNext("Hallo Welt!")
+ .expectComplete()
+ .verify();
+
+
+ server
+ .enqueue(new MockResponse()
+ .setResponseCode(HttpStatus.INTERNAL_SERVER_ERROR.value())
+ .setHeader("Content-Type", "text/plain")
+ .setBody("Hallo Welt!"));
+
+ result =
+ webClient
+ .get()
+ .uri("/egal")
+ .retrieve()
+ .bodyToMono(String.class);
+
+ StepVerifier
+ .create(result)
+ .expectError(InternalServerError.class)
+ .verify();
+ }
+