in src/main/scala/com/gu/contentapi/services/Ophan.scala [15:23]
def send(events: Seq[Event]): Int = {
events.grouped(eventsPerSecond) foreach { batch =>
Thread.sleep(1000)
batch.foreach(Ophan.send)
}
logger.info(s"Events sent to Ophan: ${events.length}")
events.length
}