consuming autosource findByStream and using for solr batch indexes.

gistfile1.scala

def batchInsert(elems: Enumerator[Iterator[T]])(implicit ctx: ExecutionContext): Future[Unit] = {
        val indexByChunks = Iteratee.foreach[Iterator[T]] { i =>
                i.grouped(batchSize).foreach { chunk =>
                        val json = Json.toJson(chunk)(Writes.seq)
                        solr.index(json)
                }
        }
        
        elems run indexByChunks
}