Hi, Assuming I have below definitions:
val flow : Flow[HttpRequest, HttpResponse, Unit] = ??? val request : HttpRequest = ??? It seems I can get a Future[Response] by doing: val response = Source.single(request).via(flow).runWith(Sink.head) I have some questions: 1. Any other ways to get the result other than above usage? 2. How can I make the call blocking in order to get a HttpResponse but not Future[HttpResponse] 3. I saw that somewhere in the document states "the back pressure is by default enabled", but for my 1 element processing, the back pressure might not needed. So what's the overhead? Can I ( or shall I) disable the back pressure in this case? (if my flow is very complex) Thanks in advance! Leon -- >>>>>>>>>> Read the docs: http://akka.io/docs/ >>>>>>>>>> Check the FAQ: >>>>>>>>>> http://doc.akka.io/docs/akka/current/additional/faq.html >>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user --- You received this message because you are subscribed to the Google Groups "Akka User List" group. To unsubscribe from this group and stop receiving emails from it, send an email to [email protected]. To post to this group, send email to [email protected]. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
