У меня есть система актеров Akka, и теперь я добавляю веб-сокет в приложение.Я хотел бы направить входящие сообщения из веб-сокета на одного актера.А от другого актера пишут сообщения в сетку.Поэтому я не могу использовать UpgradeToWebSocket # handleMessagesWith (Graph,?> HandlerFlow), так как я предполагаю, что это означает, что одно входящее сообщение возвращает одно сообщение.Например, я хочу выдвинуть 10 сообщений подряд.
Я вижу в документах эту конструкцию HttpResponse handleMessagesWith (Graph,?> InSink, Graph,?> OutSource), которая звучит как то, что я хочу.https://doc.akka.io/japi/akka/2.4.2/akka/http/javadsl/model/ws/UpgradeToWebSocket.html#handleMessagesWith-akka.stream.Graph-akka.stream.Graph-
Один из моих актеров будет тонуть, а один актер будет источником.Но я не могу найти примеров того, как на самом деле это кодировать (желательно на Java).
Или есть ли лучшие способы сделать это?