public List listAllTagsOnDeliveryStream()

in deliverystream/src/main/java/com/amazonaws/kinesisfirehose/deliverystream/FirehoseAPIWrapper.java [41:60]

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

    public List<Tag> listAllTagsOnDeliveryStream(final String deliveryStreamName, final int resultLimit) {
        String startTagKey = null;
        Boolean hasMoreTags = false;
        List<Tag> tags = new ArrayList<>();
        do {
            val req = ListTagsForDeliveryStreamRequest.builder()
                .deliveryStreamName(deliveryStreamName)
                .exclusiveStartTagKey(startTagKey)
                .limit(resultLimit)
                .build();
            val resp = clientProxy.injectCredentialsAndInvokeV2(req,
                firehoseClient::listTagsForDeliveryStream);
            if (resp.tags() != null && resp.tags().size() > 0) {
                tags.addAll(resp.tags());
                startTagKey = tags.get(tags.size() - 1).key();
                hasMoreTags = resp.hasMoreTags();
            }
        } while (hasMoreTags != null && hasMoreTags);
        return tags;
    }