From 1829adecb7b8d80d4110399b3582bbc2597492d6 Mon Sep 17 00:00:00 2001 From: Sebastien Deleuze Date: Wed, 14 Dec 2016 09:34:19 +0100 Subject: [PATCH] Disable temporarily reactor-netty in FlushingIntegrationTests --- .../reactive/FlushingIntegrationTests.java | 18 ++++++++++++++++++ 1 file changed, 18 insertions(+) diff --git a/spring-web/src/test/java/org/springframework/http/server/reactive/FlushingIntegrationTests.java b/spring-web/src/test/java/org/springframework/http/server/reactive/FlushingIntegrationTests.java index d44e7cd6ad..ee006986cb 100644 --- a/spring-web/src/test/java/org/springframework/http/server/reactive/FlushingIntegrationTests.java +++ b/spring-web/src/test/java/org/springframework/http/server/reactive/FlushingIntegrationTests.java @@ -16,11 +16,13 @@ package org.springframework.http.server.reactive; +import java.io.File; import java.nio.charset.StandardCharsets; import java.time.Duration; import org.junit.Before; import org.junit.Test; +import org.junit.runners.Parameterized; import org.reactivestreams.Publisher; import reactor.core.publisher.Flux; import reactor.core.publisher.Mono; @@ -30,6 +32,10 @@ import org.springframework.core.io.buffer.DataBuffer; import org.springframework.core.io.buffer.DataBufferFactory; import org.springframework.http.client.reactive.ReactorClientHttpConnector; import org.springframework.http.codec.BodyExtractors; +import org.springframework.http.server.reactive.bootstrap.JettyHttpServer; +import org.springframework.http.server.reactive.bootstrap.RxNettyHttpServer; +import org.springframework.http.server.reactive.bootstrap.TomcatHttpServer; +import org.springframework.http.server.reactive.bootstrap.UndertowHttpServer; import org.springframework.util.Assert; import org.springframework.web.client.reactive.ClientRequest; import org.springframework.web.client.reactive.WebClient; @@ -41,6 +47,18 @@ public class FlushingIntegrationTests extends AbstractHttpHandlerIntegrationTest private WebClient webClient; + // TODO To be removed when Reactor Netty test will be green again + @Parameterized.Parameters(name = "server [{0}]") + public static Object[][] arguments() { + File base = new File(System.getProperty("java.io.tmpdir")); + return new Object[][] { + {new JettyHttpServer()}, + {new RxNettyHttpServer()}, + {new TomcatHttpServer(base.getAbsolutePath())}, + {new UndertowHttpServer()} + }; + } + @Before public void setup() throws Exception { super.setup();