Акка Http. Поток в поток в ответ HTTP - PullRequest
Новая
       72

Акка Http. Поток в поток в ответ HTTP

0 голосов
/ 21 октября 2019

У меня есть источник 

val source = Source.actorRef[String](10, OverflowStrategy.dropTail)
                   .map(x => ChunkStreamPart(x))
                   .throttle(1, 1 seconds)

, тогда я получаю актера, который помещает элементы в мой источник 

val actor = souce.to(Sink.foreach(println))
                 .run()

Я отправляю сообщения своему актеру 

actor ! "hello"
actor ! "hello2"
actor ! "hello3"

Iхочу передать в ответ http, используя мой источник 

complete(HttpResponse(entity = HttpEntity.Chunked(ContentTypes.`text/html(UTF-8)`, source)))

Но этот приемник только печатает сообщения. Как реализовать приемник для отправки сообщений на http-ответ?

Мне нужен источник от актера.

...