ConcurrentHashSet is redundant with ConcurrentHashMap#newKeySet() #48…

…51 (#243)
vert-x3 · Sep 14, 2023 · 0fb6d39 · 0fb6d39
1 parent 3a64003
commit 0fb6d39
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 4 deletions.
diff --git a/src/test/java/io/vertx/mqtt/test/server/MqttServerTest.java b/src/test/java/io/vertx/mqtt/test/server/MqttServerTest.java
@@ -18,7 +18,6 @@
 
 import io.vertx.core.Vertx;
 import io.vertx.core.VertxOptions;
-import io.vertx.core.impl.ConcurrentHashSet;
 import io.vertx.core.impl.logging.Logger;
 import io.vertx.core.impl.logging.LoggerFactory;
 import io.vertx.ext.unit.TestContext;
@@ -81,7 +80,7 @@ public void sharedServersRoundRobin(TestContext context) {
     int numConnections = numServers * 20;
 
     List<MqttServer> servers = new ArrayList<>();
-    Set<MqttServer> connectedServers = new ConcurrentHashSet<>();
+    Set<MqttServer> connectedServers = ConcurrentHashMap.newKeySet();
 
     CountDownLatch latchListen = new CountDownLatch(numServers);
     CountDownLatch latchConns = new CountDownLatch(numConnections);

diff --git a/src/test/java/io/vertx/mqtt/test/server/MqttServerWebSocketTest.java b/src/test/java/io/vertx/mqtt/test/server/MqttServerWebSocketTest.java
@@ -19,7 +19,6 @@
 import io.vertx.core.MultiMap;
 import io.vertx.core.Vertx;
 import io.vertx.core.VertxOptions;
-import io.vertx.core.impl.ConcurrentHashSet;
 import io.vertx.core.impl.logging.Logger;
 import io.vertx.core.impl.logging.LoggerFactory;
 import io.vertx.ext.unit.Async;
@@ -75,7 +74,7 @@ public void sharedServersRoundRobin(TestContext context) {
     int numConnections = numServers * 20;
 
     List<MqttServer> servers = new ArrayList<>();
-    Set<MqttServer> connectedServers = new ConcurrentHashSet<>();
+    Set<MqttServer> connectedServers = ConcurrentHashMap.newKeySet();
 
     CountDownLatch latchListen = new CountDownLatch(numServers);
     CountDownLatch latchConns = new CountDownLatch(numConnections);