def dedupAndGroupByKey()

in src/it/scala/com/gu/kinesis/MessageUtil.scala [9:13]

• 5 lines of code
• 2 McCabe index (conditional complexity)

  def dedupAndGroupByKey(keyMessagePairs: Seq[(String, String)]): Map[String, IndexedSeq[String]] = {
    groupByKey(keyMessagePairs).map {
      case (key, value) => key -> removeReprocessed(key, value)
    }
  }