def run()

in src/main/scala/com/gu/kinesis/KinesisSource.scala [175:188]

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

  def run(): Unit = worker.run()

  def shutdownAndWait(): Unit = worker.startGracefulShutdown().get
}

private[kinesis] class RecordProcessorFactoryImpl(
    kinesisAppId: KinesisAppId,
    streamKillSwitch: KillSwitch,
    streamTerminationFuture: Future[Done],
    mergeSink: Sink[KinesisRecord, NotUsed],
    shardCheckpointConfig: ShardCheckpointConfig,
    consumerStats: ConsumerStats
)(implicit materializer: Materializer)
    extends ShardRecordProcessorFactory {