Otsos.scala

 def zip(name: String, postType: String) = Action {
    val enumerator = Enumerator.outputStream { os =>
      val zip = new ZipOutputStream(os)
      getAllBlogPosts(name, getPostType(postType)).foreach { x =>
        val url = new URL(x)
        val con = url.openConnection()
        val cc = con.asInstanceOf[HttpURLConnection].getResponseCode
        println(x + " | status: " + cc)
        if (cc == 200) {
          val in = new BufferedInputStream(url.openStream())
          zip.putNextEntry(new ZipEntry(x.reverse.takeWhile('/' !=).reverse))
          var b = in.read()
          while (b > -1) {
            zip.write(b)
            b = in.read()
          }
          in.close()
          zip.closeEntry()
        }
      }
      zip.close()
    }
    Ok.chunked(enumerator >>> Enumerator.eof).withHeaders(
      "Content-Type" -> "application/zip",
      "Content-Disposition" -> "attachment; filename=archive.zip"
    )
  }

  def outputStream(a: java.io.OutputStream => Unit): Enumerator[Array[Byte]] = {
    Concurrent.unicast[Array[Byte]] { channel =>
      val outputStream = new java.io.OutputStream() {
        override def close() = channel.end()

        override def flush() {}

        override def write(value: Int) = channel.push(Array(value.toByte))

        override def write(buffer: Array[Byte]) = write(buffer, 0, buffer.length)

        override def write(buffer: Array[Byte], start: Int, count: Int) =
          channel.push(buffer.slice(start, start + count))

      }
      a(outputStream)
    }
}