override def checkpointDelayed()

in src/it/scala/com/gu/kinesis/Inspectable.scala [64:68]

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

  override def checkpointDelayed(shardConsumerId: ShardConsumerId, e: Throwable): Unit = {
    e match {
      case _: ThrottlingException => checkpointEventsByShardConsumer.add(shardConsumerId -> CheckpointThrottled)
    }
  }