Akka-http 3,0 Ben kaygan 3.0 kullanarak ve aşağıdaki gibi ben dinlenme katman için akka-http kullanıyorum</p> <pre><code>def getAsStream = db.stream[Entity](tblquery.result) </code></pre> <p>olarak databasepublisher nesne var am

Question

Databasepublisher,

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

Nasıl Kaygan kullanarak yapabilirsiniz akışı Bu veritabanını istemci nesnesine dönüştürmek (json) ve her satırı akışa almak için kullanıyorum. Lütfen yardım et.

Answer 1

Sonunda böyle bir şey yaptığını

, onun doğru şekilde olsun,

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