Play Framework Iteratees + UNIX Pipe

poc.scala

object CLI {
  def apply(cmd: String): Enumeratee[Array[Byte], Array[Byte]] = ...
}

object Application extends Controller {

  val videoSrc = "http://ftp.nluug.nl/pub/graphics/blender/demo/movies/Sintel.2010.720p.mkv"

  def stream = Action {
    var downloadStream = Concurrent.unicast[Array[Byte]]( channel => {
      WS.url(videoSrc).get { header =>
        Iteratee.foreach[Array[Byte]](channel.push(_))
      }
    }, () => ())
    val encoder = CLI("ffmpeg -i pipe:0 -vcodec mpeg4 -s qcif -f m4v -y pipe:1")
    Ok.stream(downloadStream &> encoder).
       withHeaders( (CONTENT_TYPE, "video/mpeg"),
                    (CACHE_CONTROL, "no-cache") )
  }
  
}