def shutdown()

in src/main/scala/com/gu/contentapi/firehose/kinesis/KinesisStreamReader.scala [81:84]

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

  def shutdown(): Unit = {
    scheduler.shutdown()
    threadPool.shutdown()
  }