def concatToText()

in cassandra/src/it/scala/org/apache/pekko/projection/cassandra/CassandraProjectionSpec.scala [99:107]

• 9 lines of code
• 4 McCabe index (conditional complexity)

    def concatToText(id: String, payload: String): Future[Done] = {
      for {
        concatStr <- findById(id).map {
          case Some(concatStr) => concatStr.concat(payload)
          case _               => ConcatStr(id, payload)
        }
        _ <- session.executeWrite(s"INSERT INTO $keyspace.$table (id, concatenated) VALUES (?, ?)", id, concatStr.text)
      } yield Done
    }