diff --git a/spring-webflux/src/test/java/org/springframework/web/reactive/socket/AbstractWebSocketIntegrationTests.java b/spring-webflux/src/test/java/org/springframework/web/reactive/socket/AbstractWebSocketIntegrationTests.java index 86b1d2ac513..c81e3a5f9c4 100644 --- a/spring-webflux/src/test/java/org/springframework/web/reactive/socket/AbstractWebSocketIntegrationTests.java +++ b/spring-webflux/src/test/java/org/springframework/web/reactive/socket/AbstractWebSocketIntegrationTests.java @@ -98,7 +98,7 @@ public abstract class AbstractWebSocketIntegrationTests { servers.put(new ReactorHttpServer(), ReactorNettyConfig.class); servers.put(new UndertowHttpServer(), UndertowConfig.class); - Flux f1 = Flux.fromArray(clients).concatMap(c -> Flux.just(c).repeat(servers.size())); + Flux f1 = Flux.fromArray(clients).concatMap(c -> Flux.just(c).repeat(servers.size() - 1)); Flux f2 = Flux.fromIterable(servers.keySet()).repeat(clients.length); Flux> f3 = Flux.fromIterable(servers.values()).repeat(clients.length);