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

この databasepublisher オブジェクトを使用して、各行を変換 (json) し、クライアントにストリーミングするにはどうすればよいですか。助けてください。

Answer 1

私は最終的にこのようなことをしています、それが正しい方法かどうかはわかりませんが、

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