Подача потока Akka в источник потока akka - PullRequest
0 голосов
/ 01 февраля 2019

У меня есть веб-сокет, который подается в приемник типа Sink [T, NotUsed], который мне нужно передать в источник типа Source [T, NotUsed].Идея состоит в том, что я подключаюсь через веб-сокет к какому-либо источнику и передаю данные, полученные этим приемником, через rpc через источник.

т.е. веб-сокет -> сток [T, NotUsed] -> источник [T, NotUsed].

Спасибо.

1 Ответ

0 голосов
/ 01 февраля 2019

Вы можете взглянуть на

Flow.fromSinkAndSource(...)

https://doc.akka.io/docs/akka/current/stream/operators/Flow/fromSinkAndSource.html.

...