Application.scala

object Streams extends Controller {

  def stream = Action {
    val operations: Enumerator[JsValue] = Enumerator.generateM[JsValue] {
      Promise.timeout(
        Some( Json.obj(
          "id" -> UUID.randomUUID().toString(),
          "amount" -> Random.nextInt(1000),
          "access" -> if (Random.nextBoolean) "public" else "private"
        ) ), 
        500
      )
    }
    Ok.chunked( operations )  
  }
}