scala - Akka-http 流使用 Slick 3.0 Databasepublisher

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

我如何使用这个 databasepublisher 对象来转换(json)并将每一行流式传输到客户端。请帮忙。

Answer 1

我终于做了这样的事情，不知道是否正确，

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