CLI.pipe not working with Enumerator.generateM

[gre]

  import collection.immutable.StringOps
  import play.api.libs.concurrent.Promise.timeout
  import concurrent.{Await}
  import concurrent.duration.Duration
  val maxDuration = Duration.Inf
  val stringToBytes = (str: StringOps) => str.map(_.toByte).toArray
  val bytesJoinConsumer = Iteratee.fold[Array[Byte], Array[Byte]](Array[Byte]())((a, b) => a++b)
  val nbOfLines = 3
  val line = stringToBytes("hello\n")
  val enum = Enumerator.generateM[Array[Byte]] {
    timeout(Some(line), 5)
  }
  val pipe = CLI.pipe(Seq("head", "-n", nbOfLines.toString), 10)

  val result: Array[Byte] = Await.result(enum &> pipe |>>> bytesJoinConsumer, maxDuration)
  println(result.map(_.toChar).mkString)

[gre]

Fixed with commit c723bb8