def send()

in src/it/scala/com/gu/kinesis/ScalaKinesisProducer.scala [29:35]

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

  def send(partitionKey: String, data: ByteBuffer, explicitHashKey: Option[String] = None): Future[UserRecordResult]

  /** Performs an orderly shutdown, waiting for all the outgoing messages before destroying the underlying producer. */
  def shutdown(): Future[Unit]
}

object ScalaKinesisProducer {