Play2: Stream results of parallel jobs as comet to the client

Application.scala

package controllers

import play.api._
import play.api.mvc._


object Application extends Controller {
  
  def index = Action {

    import scala.util.Random
    import play.api.libs.iteratee._
    import play.api.libs.concurrent._

    val promises = Range(1,1000).map(i => Promise.timeout(i,Random.nextInt(100)))

    val enumerators = promises.map(p => p.map( Enumerator(_))).map(Enumerator.flatten)

    val superS = Enumerator.interleave(enumerators)

    Ok.stream((superS.map(_.toString) &> play.api.libs.Comet("console.log")) >>> Enumerator.eof)
  }
  
}