override def setOffset()

in slick/src/main/scala/org/apache/pekko/projection/slick/internal/SlickProjectionImpl.scala [228:237]

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

    override def setOffset(offset: Option[Offset]): Future[Done] = {
      offset match {
        case Some(o) =>
          val dbio = offsetStore.saveOffset(projectionId, o)
          databaseConfig.db.run(dbio).map(_ => Done)
        case None =>
          val dbio = offsetStore.clearOffset(projectionId)
          databaseConfig.db.run(dbio).map(_ => Done)
      }
    }