Почему первый тест проходит успешно, а второй — нет?
import com.github.tomakehurst.wiremock.client.ResponseDefinitionBuilder;
import com.github.tomakehurst.wiremock.junit5.WireMockRuntimeInfo;
import com.github.tomakehurst.wiremock.junit5.WireMockTest;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
import reactor.core.publisher.Mono;
import reactor.test.StepVerifier;
import org.springframework.http.HttpStatus;
import org.springframework.web.reactive.function.client.ClientResponse;
import org.springframework.web.reactive.function.client.WebClient;
import static com.github.tomakehurst.wiremock.client.WireMock.aResponse;
import static com.github.tomakehurst.wiremock.client.WireMock.get;
import static com.github.tomakehurst.wiremock.client.WireMock.stubFor;
@WireMockTest
public class GenericTest {
int port;
String responseBody;
@BeforeEach
void setUp(WireMockRuntimeInfo info) {
port = info.getHttpPort();
responseBody = "response-body";
ResponseDefinitionBuilder response = aResponse()
.withStatus(HttpStatus.OK.value())
.withBody(responseBody);
stubFor(get("/test").willReturn(response));
}
@Test
void test1() {
Mono bodyMono = WebClient.builder()
.baseUrl("http://localhost:%d".formatted(port))
.build()
.get()
.uri("/test")
.retrieve()
.bodyToMono(String.class);
StepVerifier.create(bodyMono)
.expectNext(responseBody)
.verifyComplete();
}
@Test
void test2() {
Mono responseMono = WebClient.builder()
.baseUrl("http://localhost:%d".formatted(port))
.build()
.get()
.uri("/test")
.exchangeToMono(Mono::just);
StepVerifier.create(responseMono.flatMap(r -> r.bodyToMono(String.class)))
.expectNext(responseBody)
.verifyComplete();
}
}
java.lang.AssertionError: expectation "expectNext(response-body)" failed (expected: onNext(response-body); actual: onComplete())
Мне нужно конкретно утвердить ClientResponse. У него есть ожидаемый статус и заголовки, но тело всегда пусто (хотя это и не должно быть). Сначала я попробовал вызвать ReleaseBody(), но это не помогло
// passes
StepVerifier.create(responseMono.flatMap(ClientResponse::releaseBody))
.verifyComplete();
// still fails
StepVerifier.create(responseMono.flatMap(r -> r.bodyToMono(String.class)))
.expectNext(responseBody)
.verifyComplete();
Подробнее здесь: https://stackoverflow.com/questions/782 ... ntresponse