Grouping an Enumerator by size (Playframework)

GroupEnumerator.scala

import play.api.libs.iteratee.Enumerator
import play.api.libs.iteratee.Enumeratee
import play.api.libs.iteratee.Iteratee

def grouped[T](enumerator: Enumerator[T], groupSize: Int): Enumerator[List[T]] = {
  val groupingIteratee = Enumeratee.take[T](groupSize) &>> Iteratee.getChunks
  val groupingEnumeratee = Enumeratee.grouped(groupingIteratee)
  enumerator &> groupingEnumeratee
}

import scala.concurrent.Await
import scala.concurrent.duration.Duration

val e = Enumerator((1 to 1000) : _*)
val groupedE = grouped(e, 5)
val r = groupedE.run(Iteratee.getChunks)
println(Await.result(r, Duration.Inf))