private def checkpointCountByShardConsumer()

in src/it/scala/com/gu/kinesis/Inspectable.scala [95:101]

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

  private def checkpointCountByShardConsumer(): MapView[ShardConsumerId, Int] = {
    checkpointEventsByShardConsumer.asScala.toIndexedSeq
      .filter { case (_, event) => event == CheckpointAcked }
      .groupBy { case (key, _) => key }
      .view
      .mapValues(_.size)
  }