reporter.scala

final class Reporter(scheduler: Scheduler) extends Observable[Payload] {
  
  implicit val s = scheduler
  
  // TODO define overflow strategy.
  private val subject = ConcurrentSubject.publish[Payload]()      

  def unsafeSubscribeFn(subscriber: Subscriber[Payload]): Cancelable = {
    subject.unsafeSubscribeFn(subscriber)
  }    
  
  post("/endpoint") { request =>
    val payload = parsePayload(request)
    subject.onNext(payload)
  }
}