def apply()

in src/it/scala/com/gu/kinesis/ScalaKinesisProducer.scala [45:53]

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

  def apply(
    streamName: String,
    kplConfig: KinesisProducerConfiguration,
    producerStats: ProducerStats
  ): ScalaKinesisProducer = {
    val streamId = StreamId(kplConfig.getRegion, streamName)
    val producer = new KinesisProducer(kplConfig)
    new ScalaKinesisProducerImpl(streamId, producer, producerStats)
  }