@Override
  public void add(final PeerConnection newConnection) {
    final Address peerAddress = newConnection.getPeerInfo().getAddress();
    final Set<PeerConnection> connections =
        connectionsByAddress.computeIfAbsent(
            peerAddress, (k) -> Collections.newSetFromMap(new ConcurrentHashMap<>()));
    connections.add(newConnection);
  }
Instantiates a new Validator peers.

@param validatorProvider the validator provider
@param protocolName the protocol name
consensus/common/src/main/java/org/hyperledger/besu/consensus/common/bft/network/ValidatorPeers.java