def groupByKey()

in src/it/scala/com/gu/kinesis/MessageUtil.scala [15:22]

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

  def groupByKey(keyMessagePairs: Seq[(String, String)]): Map[String, IndexedSeq[String]] = {
    keyMessagePairs.toIndexedSeq
      .groupBy { case (key, _) => key }
      .view
      .mapValues { keysWithMessages =>
        keysWithMessages.map { case (_, message) => message }
      }
  }.toMap