private static void waitForKdsDeletion()

in src/main/java/software/amazon/qldb/tutorial/streams/StreamJournal.java [631:657]

• 24 lines of code
• 6 McCabe index (conditional complexity)

    private static void waitForKdsDeletion() {
        DescribeStreamRequest describeStreamRequest = new DescribeStreamRequest();
        describeStreamRequest.setStreamName(kdsName);

        int retries = 0;
        while (retries < MAX_RETRIES) {
            try {
                Thread.sleep(20 * 1000);
            } catch (Exception ignore) {
            }

            try {
                kinesis.describeStream(describeStreamRequest);
            } catch (ResourceNotFoundException ex) {
                break;
            }

            try {
                Thread.sleep(1000);
            } catch (Exception ignore) {
            }
            retries++;
        }
        if (retries >= MAX_RETRIES) {
            throw new RuntimeException("Kinesis Stream with name " + kdsName + " could not be deleted.");
        }
    }