chunkUntil for scalaz-stream

chunkUntil.scala

def chunkUntil[I](emit: I => Boolean): Process1[I, Vector[I]] = {
  def go(acc: Vector[I]): Process1[I, Vector[I]] =
    Process.receive1Or[I,Vector[I]](Process.emit(acc)) { i =>
      val chunk = acc :+ i
      if (emit(i)) Process.emit(chunk) ++ go(Vector())
      else go(chunk)
    }
  go(Vector())
}