def deserializeEvents()

in src/main/scala/com/gu/fastly/CrierEventDeserializer.scala [13:25]

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

  def deserializeEvents(scala: mutable.Buffer[UserRecord]): Seq[Event] = {
    scala.flatMap { record =>
      CrierEventDeserializer.eventFromRecord(record) match {
        case Success(event) =>
          Some(event)
        case Failure(error) =>
          println(
            "Failed to deserialize Crier event from Kinesis record. Skipping."
          )
          None
      }
    }
  }