def send()

in src/it/scala/com/gu/kinesis/ScalaKinesisProducer.scala [74:80]

• 7 lines of code
• 2 McCabe index (conditional complexity)

  def send(partitionKey: String, data: ByteBuffer, explicitHashKey: Option[String]): Future[UserRecordResult] = {
    stats.trackSend(streamId, data.remaining) {
      producer.addUserRecord(streamId.streamName, partitionKey, explicitHashKey.orNull, data).map { result =>
        if (!result.isSuccessful) throwSendFailedException(result) else result
      }
    }
  }