private def throttledCheckpointsCount()

in src/it/scala/com/gu/kinesis/Inspectable.scala [103:106]

• 4 lines of code
• 2 McCabe index (conditional complexity)

  private def throttledCheckpointsCount(): Int = {
    checkpointEventsByShardConsumer.asScala
      .count { case (_, event) => event == CheckpointThrottled }
  }