使用 Slick 3.0 Databasepublisher 的 Akka-http 流式传输

Question

我正在使用 slick 3.0 并且有一个 databasepublisher 对象

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

我正在使用 akka-http 作为休息层，如下所示，

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))
         }