def apply()

in src/it/scala/com/gu/kinesis/ScalaKinesisProducer.scala [36:43]

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

  def apply(
    streamName: String,
    kplConfig: KinesisProducerConfiguration,
    config: Config = ConfigFactory.load()
  ): ScalaKinesisProducer = {
    val producerStats = ProducerStats.getInstance(config)
    ScalaKinesisProducer(streamName, kplConfig, producerStats)
  }