public void prepare()

in src/main/java/com/amazonaws/mskdatagen/core/TopicSequenceGenerator.java [24:44]

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

    public void prepare() {
        List<String> collect = context.getGenerators()
                .map(GeneratorsConfigs::getTopic).collect(Collectors.toList());

        List<ContextConfig> topicsSeq = new CopyOnWriteArrayList<>();
        context.getContextMap().put(ConfigType.TOPIC_SEQ_CONFIG, topicsSeq);

        CompletableFuture.runAsync(() -> {
            int i = 1;
            while (i > 0) {
                int k = i / collect.size();

                TopicSeqConfig topicSeqConfig = new TopicSeqConfig(collect.get(i - (k * collect.size())));
                topicsSeq.add(topicSeqConfig);
                i++;
                if (i == Integer.MIN_VALUE) {
                    i = 1;
                }
            }
        });
    }