Акка Потоки и HTTP. Внешний HTTP-запрос в версии 1.0-RC4

Этот код больше не работает при попытке создать http-клиент/поток:

lazy val myConnectionFlow = 
 Http().outgoingConnection("localhost", port).flow

def myRequest(request: HttpRequest): Future[HttpResponse] = 
 Source.single(request).via(myConnectionFlow).runWith(Sink.head)

Кажется, метод flow больше недоступен. Действительно ли он устарел? Является ли следующий предпочтительным способом создания Http-соединений?

 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)

person Azeli    schedule 15.08.2015    source источник


Ответы (1)


Да. Для экспериментальных модулей нет периода устаревания, в частности, до достижения версии 1.0.

person Roland Kuhn    schedule 15.08.2015