def send()

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
  }