diff --git a/reactor-netty5-core/src/test/java/reactor/netty5/tcp/BlockingConnectionTest.java b/reactor-netty5-core/src/test/java/reactor/netty5/tcp/BlockingConnectionTest.java index aa3bd22bf9..ef5b5693dd 100644 --- a/reactor-netty5-core/src/test/java/reactor/netty5/tcp/BlockingConnectionTest.java +++ b/reactor-netty5-core/src/test/java/reactor/netty5/tcp/BlockingConnectionTest.java @@ -26,6 +26,7 @@ import io.netty5.handler.logging.LoggingHandler; import io.netty5.resolver.AddressResolverGroup; import io.netty5.resolver.DefaultAddressResolverGroup; +import org.junit.jupiter.api.Disabled; import org.junit.jupiter.api.Test; import reactor.core.publisher.Flux; import reactor.core.publisher.Mono; @@ -86,6 +87,7 @@ public int port() { }; @Test + @Disabled void simpleServerFromAsyncServer() { DisposableServer simpleServer = TcpServer.create() diff --git a/reactor-netty5-core/src/test/java/reactor/netty5/tcp/TcpClientTests.java b/reactor-netty5-core/src/test/java/reactor/netty5/tcp/TcpClientTests.java index 9b3cce23c1..631cb1f362 100644 --- a/reactor-netty5-core/src/test/java/reactor/netty5/tcp/TcpClientTests.java +++ b/reactor-netty5-core/src/test/java/reactor/netty5/tcp/TcpClientTests.java @@ -51,6 +51,7 @@ import io.netty5.resolver.DefaultAddressResolverGroup; import org.junit.jupiter.api.AfterEach; import org.junit.jupiter.api.BeforeEach; +import org.junit.jupiter.api.Disabled; import org.junit.jupiter.api.Test; import org.reactivestreams.Publisher; import reactor.core.publisher.Flux; @@ -289,6 +290,7 @@ void tcpConnectionInboundAndOutboundCompletesOnDispose() throws Exception { } @Test + @Disabled void tcpClientHandlesLineFeedDataFixedPool() throws InterruptedException { Consumer channelInit = c -> c.addHandlerLast("codec", new LineBasedFrameDecoder(8 * 1024)); @@ -302,6 +304,7 @@ void tcpClientHandlesLineFeedDataFixedPool() throws InterruptedException { } @Test + @Disabled void tcpClientHandlesLineFeedDataElasticPool() throws InterruptedException { Consumer channelInit = c -> c.addHandlerLast("codec", new LineBasedFrameDecoder(8 * 1024)); diff --git a/reactor-netty5-core/src/test/java/reactor/netty5/tcp/TcpServerTests.java b/reactor-netty5-core/src/test/java/reactor/netty5/tcp/TcpServerTests.java index c319277b53..d222598a55 100644 --- a/reactor-netty5-core/src/test/java/reactor/netty5/tcp/TcpServerTests.java +++ b/reactor-netty5-core/src/test/java/reactor/netty5/tcp/TcpServerTests.java @@ -65,6 +65,7 @@ import io.netty5.util.concurrent.EventExecutor; import org.junit.jupiter.api.AfterAll; import org.junit.jupiter.api.BeforeAll; +import org.junit.jupiter.api.Disabled; import org.junit.jupiter.api.Test; import org.junit.jupiter.api.Timeout; import org.reactivestreams.Publisher; @@ -536,6 +537,7 @@ void startAndAwait() throws InterruptedException { } @Test + @Disabled void tcpServerCanEncodeAndDecodeJSON() throws Exception { ObjectMapper mapper = new ObjectMapper(); Function jsonEncoder = pojo -> { @@ -663,6 +665,7 @@ void flushEvery5ElementsWithManualDecoding() throws Exception { } @Test + @Disabled void retryStrategiesWhenServerFails() throws Exception { ObjectMapper mapper = new ObjectMapper(); Function, Buffer> jsonEncoder = pojo -> { @@ -739,6 +742,7 @@ void retryStrategiesWhenServerFails() throws Exception { } @Test + @Disabled void testEchoWithLineBasedFrameDecoder() throws Exception { CountDownLatch latch = new CountDownLatch(2); DisposableServer server = @@ -909,6 +913,7 @@ void testHalfClosedConnection() throws Exception { } @Test + @Disabled void testGracefulShutdown() throws Exception { CountDownLatch latch1 = new CountDownLatch(2); CountDownLatch latch2 = new CountDownLatch(2); diff --git a/reactor-netty5-http/src/test/java/reactor/netty5/http/HttpProtocolsTests.java b/reactor-netty5-http/src/test/java/reactor/netty5/http/HttpProtocolsTests.java index de494e3c4d..cdf0ee050e 100644 --- a/reactor-netty5-http/src/test/java/reactor/netty5/http/HttpProtocolsTests.java +++ b/reactor-netty5-http/src/test/java/reactor/netty5/http/HttpProtocolsTests.java @@ -32,6 +32,7 @@ import io.netty5.handler.timeout.ReadTimeoutHandler; import io.netty5.util.concurrent.DefaultPromise; import org.junit.jupiter.api.AfterAll; +import org.junit.jupiter.api.Disabled; import org.junit.jupiter.params.ParameterizedTest; import org.junit.jupiter.params.provider.MethodSource; import org.mockito.Mockito; @@ -382,6 +383,7 @@ void testAccessLog(HttpServer server, HttpClient client) throws Exception { } @ParameterizedCompatibleCombinationsTest + @Disabled void testResponseTimeout(HttpServer server, HttpClient client) throws Exception { disposableServer = server.handle((req, res) -> res.sendString(Mono.just("testProtocolVariationsResponseTimeout"))) diff --git a/reactor-netty5-http/src/test/java/reactor/netty5/http/client/HttpClientTest.java b/reactor-netty5-http/src/test/java/reactor/netty5/http/client/HttpClientTest.java index 78df8eafab..7e4c477300 100644 --- a/reactor-netty5-http/src/test/java/reactor/netty5/http/client/HttpClientTest.java +++ b/reactor-netty5-http/src/test/java/reactor/netty5/http/client/HttpClientTest.java @@ -93,6 +93,7 @@ import io.netty5.util.concurrent.EventExecutor; import org.junit.jupiter.api.AfterAll; import org.junit.jupiter.api.BeforeAll; +import org.junit.jupiter.api.Disabled; import org.junit.jupiter.api.Test; import org.reactivestreams.Publisher; import reactor.core.publisher.Flux; @@ -2882,6 +2883,7 @@ void testCustomHandlerAddedOnChannelInitAlwaysAvailable() { } @Test + @Disabled void testCustomHandlerAddedOnChannelConnectedAlwaysAvailable() { doTestCustomHandlerAddedOnCallbackAlwaysAvailable( client -> client.doOnConnected(conn -> conn.addHandlerLast("custom", new ChannelHandlerAdapter(){}))); diff --git a/reactor-netty5-http/src/test/java/reactor/netty5/http/client/HttpRedirectTest.java b/reactor-netty5-http/src/test/java/reactor/netty5/http/client/HttpRedirectTest.java index 215c1f59fa..6616f85bb1 100644 --- a/reactor-netty5-http/src/test/java/reactor/netty5/http/client/HttpRedirectTest.java +++ b/reactor-netty5-http/src/test/java/reactor/netty5/http/client/HttpRedirectTest.java @@ -38,6 +38,7 @@ import io.netty5.handler.ssl.util.SelfSignedCertificate; import org.apache.commons.lang3.StringUtils; import org.junit.jupiter.api.BeforeAll; +import org.junit.jupiter.api.Disabled; import org.junit.jupiter.api.Test; import reactor.core.publisher.Flux; import reactor.core.publisher.Mono; @@ -674,11 +675,13 @@ void testLastLocationSetToResourceUrlOnRedirect() { } @Test + @Disabled void testBuffersForRedirectWithContentShouldBeReleased() { doTestBuffersForRedirectWithContentShouldBeReleased("Redirect response content!"); } @Test + @Disabled void testBuffersForRedirectWithLargeContentShouldBeReleased() { doTestBuffersForRedirectWithContentShouldBeReleased(StringUtils.repeat("a", 10000)); } diff --git a/reactor-netty5-http/src/test/java/reactor/netty5/http/server/HttpServerTests.java b/reactor-netty5-http/src/test/java/reactor/netty5/http/server/HttpServerTests.java index ffa1bf8e2c..ffd65fa5e4 100644 --- a/reactor-netty5-http/src/test/java/reactor/netty5/http/server/HttpServerTests.java +++ b/reactor-netty5-http/src/test/java/reactor/netty5/http/server/HttpServerTests.java @@ -88,6 +88,7 @@ import org.junit.jupiter.api.AfterAll; import org.junit.jupiter.api.AfterEach; import org.junit.jupiter.api.BeforeAll; +import org.junit.jupiter.api.Disabled; import org.junit.jupiter.api.Test; import org.junit.jupiter.api.Timeout; import org.junit.jupiter.params.ParameterizedTest; @@ -1725,6 +1726,7 @@ void testIssue1001() throws Exception { } @Test + @Disabled void testGracefulShutdown() throws Exception { CountDownLatch latch1 = new CountDownLatch(2); CountDownLatch latch2 = new CountDownLatch(2);