public static void waitForStreamStatus()

in src/main/java/com/amazonaws/services/kinesis/scaling/StreamScalingUtils.java [96:113]

• 15 lines of code
• 3 McCabe index (conditional complexity)

	public static void waitForStreamStatus(KinesisClient kinesisClient, String streamName, String status)
			throws Exception {
		boolean ok = false;
		String streamStatus;
		// stream mutation takes around 30 seconds, so we'll start with 20 as
		// a timeout
		int waitTimeout = 20000;
		do {
			streamStatus = getStreamStatus(kinesisClient, streamName);
			if (!streamStatus.equals(status)) {
				Thread.sleep(waitTimeout);
				// reduce the wait timeout from the initial wait time
				waitTimeout = 1000;
			} else {
				ok = true;
			}
		} while (!ok);
	}