def markProcessed()

in src/main/scala/com/gu/kinesis/KinesisRecord.scala [36:43]

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

  def markProcessed(): Unit = completionPromise.trySuccess(Done)

  private[kinesis] def offsetString: String = {
    subSequenceNumber match {
      case Some(definedSubSequence) => s"Offset(sequenceNumber=$sequenceNumber, subSequenceNumber=$definedSubSequence)"
      case None => s"Offset(sequenceNumber=$sequenceNumber)"
    }
  }