阿卡-HTTP使用油滑3.0 Databasepublisher

Question

我使用光滑3.0和有databasepublisher對象

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

我使用阿卡-HTTP休息層如下，

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

如何流可以我使用這個databasepublisher對象來轉換（json）並將每一行傳送到客戶端。請幫忙。

Answer 1

我終於做這樣的事情，不知道是不是它的正確的方式，

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