bug fix in chain resolver.

This commit is contained in:
Jan 2025-09-27 20:21:24 +02:00
parent 3a9691dc6f
commit c39ef5f4ee

View file

@ -81,7 +81,7 @@ public class ChainResolver {
}
// remove chains if there is a node that cannot act as intermediate.
foundChains = foundChains.stream().filter(chain -> chain.stream().anyMatch(n -> !n.getIntermediate())).toList();
foundChains = foundChains.stream().filter(chain -> chain.stream().allMatch(n -> n.getIntermediate())).toList();
log.info("Found {} chains for node {}", foundChains.size(), nodeId);