Отправка сообщений через веб-сокеты с помощью akka http

Question

Я использую akka http 2.0.3 для приложения и хочу использовать веб-сокеты. Я хочу, чтобы иметь возможность передавать сообщения с сервера на клиент, без необходимости получать сообщение в первую очередь. Итак, я смотрел на признак UpgradeToWebsocket, и казалось, что использование handleMessagesWithSinkSource было бы правильным. Теперь, для отправки сообщений, я хотел, чтобы актер был подключен к источнику, который передается методу handleMessagesWithSinkSource. Однако при использовании метода Source.actorRef создается впечатление, что актер генерируется только при запуске потока, что будет в методе handleMessagesWithSinkSource.

Итак, мой вопрос, как отправить сообщения на канал веб-сокета, предпочтительно через актера?

Answer 1

Обнаружено, что можно передать ActorPublisher на источник:

Source.fromPublisher(ActorPublisher(myActorPublisher)

Таким образом, сначала создается экземпляр издателя, а затем передается в Source, который затем передается в handleMessagesWithSinkSource.