def fromMutableRecord()

in src/main/scala/com/gu/kinesis/KinesisRecord.scala [47:57]

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

  def fromMutableRecord(record: KinesisClientRecord): KinesisRecord = {
    KinesisRecord(
      data = ByteString(record.data()),
      partitionKey = record.partitionKey(),
      explicitHashKey = Option(record.explicitHashKey()),
      sequenceNumber = record.sequenceNumber(),
      subSequenceNumber = Option(record.subSequenceNumber()),
      approximateArrivalTimestamp = record.approximateArrivalTimestamp(),
      encryptionType = Option(record.encryptionType())
    )
  }