protected def producerSink[A]()

in src/it/scala/com/gu/kinesis/KinesisTestComponents.scala [49:51]

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

  protected def producerSink[A](implicit config: TestStreamConfig): Sink[KeyAndMessage, Future[Seq[KeyAndMessage]]] = {
    KinesisTestProducer.sink(config.streamName, config.kplConfig)
  }