2015-08-15 3 views
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) 

ответ

0

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

Смежные вопросы