protected def buildConfig()

in src/it/scala/com/gu/kinesis/KinesisTestComponents.scala [22:30]

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

  protected def buildConfig(tags: Set[String]): TestStreamConfig = {
    tags.foldLeft(TestStreamConfig.fromRandomUuid()) {
      case (currentConfig, ThrottledByCheckpoint.name) =>
        currentConfig.copy(checkpointAfterCompletingNrOfRecords = 1, idleTimeBetweenGetRecords = 1.millis)

      case (currentConfig, _) =>
        currentConfig
    }
  }