我使用光滑3.0和有databasepublisher對象 def getAsStream = db.stream[Entity](tblquery.result)
我使用阿卡-HTTP休息層如下, val route =
path("stream"){
get {
complete { // how to stream from here }
}
}
如何流可以
我想在其上創建Source,後來推元素,如在: val src = ... // create the Source here
// and then, do something like this
pushElement(x1, src)
pushElement(x2, src)
什麼是推薦的方式做到這一點? 謝謝!
我使用時如何完成其他演員的要求阿卡-HTTP 1.0,我想用定義爲 def route: Route = path("") {
// start actor with requestContext
// call requestContext.complete(...) in actor with the result
}
如何做到這一點的路線?