假设我设置了一个任意复杂的Flow[HttpRequest, HttpResponse, Unit]
.
我已经可以使用所述流程来处理传入请求
Http().bindAndHandle(flow, "0.0.0.0", 8080)
现在我想添加日志记录,利用一些现有的指令,例如logRequestResult("my-service"){...}
有没有办法将此指令与我的流程结合起来?我想我正在寻找另一个指令,类似于
def completeWithFlow(flow: Flow): Route
这有可能吗?
注意:logRequestResult 是一个例子,我的问题适用于任何可能有用的指令。
事实证明,一种(也许是唯一)方法是连接并具体化一个新流程,并将提取的请求提供给它。下面的例子
val myFlow: Flow[HttpRequest, HttpResponse, NotUsed] = ???
val route =
get {
logRequestResult("my-service") {
extract(_.request) { req ⇒
val futureResponse = Source.single(req).via(myFlow).runWith(Sink.head)
complete(futureResponse)
}
}
}
Http().bindAndHandle(route, "127.0.0.1", 9000)
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)