akka-http：フロー付きの完全リクエスト

Question

任意の複合体Flow[HttpRequest, HttpResponse, Unit]を設定したとします。

私はすでに今、私は私の流れでこのディレクティブを結合する方法はありlogRequestResult("my-service"){...} のように、いくつかの既存のディレクティブを活用し、ロギングを追加したいフローが

Http().bindAndHandle(flow, "0.0.0.0", 8080) 

で着信要求を処理するために言った使用することができますか？私は別の指令を探していると思います。

def completeWithFlow(flow: Flow): Route 

これはまったく可能ですか？

N.B .: logRequestResultが例ですが、私の質問は役に立つと思われる任意のディレクティブに適用されます。

Answer 1

は1をオン（そしておそらく唯一の）方法は、ワイヤと新しい流れを実体、およびそれに抽出された要求を供給することです。以下の例

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) 

Answer 2

http://doc.akka.io/docs/akka/2.4.2/scala/http/routing-dsl/overview.html

あなたはroute2HandlerFlowやRoute.handlerFlowをお探しですか？

Route.handlerFlowはimplicitに基づいて動作します。

例えば/

val serverBinding = Http().bindAndHandle(interface = "0.0.0.0", port = 8080, 
handler = route2HandlerFlow(mainFlow()))