Akka-http strumieniowe za pomocą Slick 3,0 Databasepublisher

Question

Używam zręczny 3.0 i posiada databasepublisher obiekt jako

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

używam Akka-http dla warstwy spoczynku następująco,

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

Jak można Używam tego obiektu bazy danych, aby przekształcić (json) i przesłać każdy wiersz do klienta. Proszę pomóż.

Answer 1

I wreszcie robi coś takiego, nie wiem, czy jego odpowiedni sposób,

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