Суть - есть сервис, написанный на akka-grpc. Один из grpc методов должен возвращать stream, что в akka-grpc превращается в Source[Record, NotUsed] (который из akka-streams). Теперь мне нужно из актора этот Source наполнить. Как это правильно сделать? Должен же быть какой-то интеграционный механизм между Akka Actors и Akka Streams?
хороший вопрос, у меня есть вот такое говно https://github.com/scalacenter/scastie/blob/master/utils/src/main/scala/com.olegych.scastie/util/GraphStageForwarder.scala
можно создать Source.actorRef и вмёржить его в готовый Source https://scastie.scala-lang.org/5ycNaAPbRIiLiTlAs9u70w
Обсуждают сегодня