Акка-HTTP потоковые с помощью Slick 3,0 Databasepublisher

Question

Я использую скользкий 3.0 и имею databasepublisher объекта как

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

Я использую Акку-клиент для отдыха слоя следующим образом,

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

Как Я использую этот объект базы данных, чтобы преобразовать (json) и передать каждую строку клиенту. Пожалуйста помоги.

Answer 1

я, наконец, сделать что-то вроде этого, не знаю, является ли его правильно,

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