private void addToClosedLeafNodes()

in src/main/java/com/amazonaws/services/dynamodbv2/streamsadapter/DynamoDBStreamsProxy.java [514:533]

• 20 lines of code
• 7 McCabe index (conditional complexity)

        private void addToClosedLeafNodes(List<Shard> shards) {
            if (null == shards) {
                return;
            }
            if (LOG.isDebugEnabled()) {
                LOG.debug(String.format("Attempting to resolve inconsistencies in the graph with the following shards: \n %s",
                    String.join(", ", shards.stream().map(Shard::getShardId).collect(Collectors.toList()))));
            }
            for (Shard shard : shards) {
                final String parentShardId = shard.getParentShardId();
                if (null != parentShardId && closedLeafNodeIds.contains(parentShardId)) {
                    ShardNode shardNode = addNode(shard);
                    closedLeafNodeIds.remove(parentShardId);
                    if (shardNode.isShardClosed()) {
                        closedLeafNodeIds.add(shardNode.getShardId());
                    }
                }
            }
            updateLastFetchedShardId(shards);
        }