def waitForNrOfThrottledCheckpoints()

in src/it/scala/com/gu/kinesis/Inspectable.scala [89:93]

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

  def waitForNrOfThrottledCheckpoints(throttledCount: Int)(implicit patienceConfig: PatienceConfig): Unit = {
    eventually {
      require(throttledCheckpointsCount() >= throttledCount)
    }
  }