From: Kai Moritz Date: Thu, 21 Nov 2019 08:35:13 +0000 (+0100) Subject: WIP: WebClient X-Git-Tag: wip-webclient~33 X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=58021336ff2b6f6e16a0e070d093b61dee8dbc6f;p=facebook-errors WIP: WebClient --- diff --git a/pom.xml b/pom.xml index 2e09f82..5a77b37 100644 --- a/pom.xml +++ b/pom.xml @@ -116,6 +116,11 @@ reactor-test test + + org.eclipse.jetty + jetty-reactive-httpclient + test + javax.servlet javax.servlet-api diff --git a/src/test/java/de/juplo/facebook/errors/GraphApiExchangeFilterFunctionIntegrationTest.java b/src/test/java/de/juplo/facebook/errors/GraphApiExchangeFilterFunctionIntegrationTest.java index 640fa6a..87c3fe6 100644 --- a/src/test/java/de/juplo/facebook/errors/GraphApiExchangeFilterFunctionIntegrationTest.java +++ b/src/test/java/de/juplo/facebook/errors/GraphApiExchangeFilterFunctionIntegrationTest.java @@ -9,8 +9,13 @@ import org.junit.After; import static org.junit.Assert.assertEquals; import org.junit.Before; import org.junit.Test; +import org.junit.runner.RunWith; +import org.junit.runners.Parameterized; import org.slf4j.Logger; import org.slf4j.LoggerFactory; +import org.springframework.http.client.reactive.ClientHttpConnector; +import org.springframework.http.client.reactive.JettyClientHttpConnector; +import org.springframework.http.client.reactive.ReactorClientHttpConnector; import org.springframework.web.reactive.function.client.WebClient; import reactor.core.publisher.Mono; import reactor.test.StepVerifier; @@ -20,6 +25,7 @@ import reactor.test.StepVerifier; * * @author Kai Moritz */ +@RunWith(Parameterized.class) public class GraphApiExchangeFilterFunctionIntegrationTest { private static final Logger LOG = @@ -28,6 +34,19 @@ public class GraphApiExchangeFilterFunctionIntegrationTest private MockWebServer server; private WebClient webClient; + @Parameterized.Parameter(0) + public ClientHttpConnector connector; + + @Parameterized.Parameters(name = "webClient [{0}]") + public static Object[][] arguments() + { + return new Object[][] + { + { new JettyClientHttpConnector() }, + { new ReactorClientHttpConnector() } + }; + } + @Before public void setup() @@ -36,6 +55,7 @@ public class GraphApiExchangeFilterFunctionIntegrationTest webClient = WebClient .builder() + .clientConnector(this.connector) .baseUrl(server.url("/").toString()) .filter(GraphApiExchangeFilterFunction.INSTANCE) .build();