1
Этот код не кажется, работать больше при попытке создать HTTP-клиент/поток:Akka Streams & Http. Внешний запрос Http в версии 1.0-RC4
lazy val myConnectionFlow =
Http().outgoingConnection("localhost", port).flow
def myRequest(request: HttpRequest): Future[HttpResponse] =
Source.single(request).via(myConnectionFlow).runWith(Sink.head)
Кажется метод flow
больше не доступен. Действительно ли это было устарело? Является ли теперь предпочтительным способом создания Http Connections?
val connFlow: Flow[HttpRequest, HttpResponse, Future[Http.OutgoingConnection]] =
Http().outgoingConnection("localhost", port)
val responseFuture: Future[HttpResponse] =
Source.single(HttpRequest(uri="XXX"))
.via(connFlow).runWith(Sink.head)