override def getObject()

in core/src/main/scala/org/apache/pekko/persistence/jdbc/state/scaladsl/JdbcDurableStateStore.scala [73:85]

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

  override def getObject(persistenceId: String): Future[stateScalaDsl.GetObjectResult[A]] = {
    db.run(queries.selectFromDbByPersistenceId(persistenceId).result).map { rows =>
      rows.headOption match {
        case Some(row) =>
          stateScalaDsl.GetObjectResult(
            PekkoSerialization.fromDurableStateRow(serialization)(row).toOption.asInstanceOf[Option[A]],
            row.revision)

        case None =>
          stateScalaDsl.GetObjectResult(None, 0)
      }
    }
  }