class ShardInfoDownloader {

    public void processAllPeersShardingInfo() {
        //remove not-sharding peers
        shardInfoByPeers.entrySet().removeIf(
            entry -> (entry.getValue().isShardingOff == true)
        );
        shardInfoByPeers.keySet().forEach((pa) -> {
            processPeerShardingInfo(pa, shardInfoByPeers.get(pa));
        });
        log.debug("ShardingInfo requesting result {}", sortedByIdShards);
        sortedByIdShards.keySet().forEach((idx) -> {
            shardsDesisons.put(idx, checkShard(idx));
        });
    }

    @Inject public  ShardInfoDownloader(PeersService peers);

}