Akka-streaming HTTP usando Slick 3.0 Databasepublisher

Question

Sto usando chiazza di petrolio 3.0 e dispone di un oggetto databasepublisher come

def getAsStream = db.stream[Entity](tblquery.result) 

Sto usando Akka-http per lo strato di riposo come segue,

val route = 
path("stream"){ 
get { 
    complete { // how to stream from here } 
    } 
} 

Come si può Uso questo oggetto databasepublisher, per trasformare (json) e trasmettere ogni riga al client. Per favore aiuto.

Answer 1

ho finalmente fare qualcosa di simile, non so se il suo modo giusto,

complete { 
     val source = Source(repository.getAsStream).map(a => ChunkStreamPart(a.asJson)) 
     HttpResponse(entity = HttpEntity.Chunked(MediaTypes.`application/json`, source)) 
     }