Fix concurrent modification exception in IPNS publish

Peergos · Dec 13, 2023 · c1f2a46 · c1f2a46
1 parent 4bba117
commit c1f2a46
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/main/java/org/peergos/protocol/dht/Kademlia.java b/src/main/java/org/peergos/protocol/dht/Kademlia.java
@@ -388,7 +388,7 @@ public CompletableFuture<Void> publishValue(PrivKey priv,
             if (toQuery.size() == remaining) {
                 // publish to closest remaining nodes
                 while (publishes.size() < minPublishes) {
-                    List<RoutingEntry> closest = toQuery.stream()
+                    List<RoutingEntry> closest = new TreeSet<>(toQuery).stream()
                     .limit(minPublishes - publishes.size() + 5)
                     .collect(Collectors.toList());
                     List<? extends Future<?>> lastFutures = closest.stream()