gistfile1.scala

import play.api.libs.iteratee._

object EnumeratorHang {
    def main(args: Array[String]) {
        implicit val ec = scala.concurrent.ExecutionContext.Implicits.global

        val enumerator = Concurrent.unicast[String] { channel =>
            channel.push("foo")
            channel.push("bar")
            channel.end()
        }

        val future = enumerator.run(Iteratee.fold[String, String]("")(
            (acc, s) => {
                println(s)
                acc + " " + s
            }))

        future onSuccess {
            case result =>
                println("Result: " + result)
        }
    }
}