def start()

in src/main/scala/com/gu/contentapi/firehose/kinesis/KinesisStreamReader.scala [75:79]

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

  def start(): Thread = {
    workerThread.start()
    checkApiAccess(kinesisClient, kinesisStreamReaderConfig.streamName)
    workerThread
  }