Akka HTTP - Websocket - истинный двунаправленный сценарий

Попытка создать настоящий двунаправленный сервер websocket с помощью akka http и akka-stream

• Сервер ответит на запрос, когда ответ будет готов
• Сервер ответит на запрос несколькими ответами, когда они будут готовы
• Сервер отправит уведомление без каких-либо запросов

Официальный https://doc.akka.io/docs/akka-http/current/server-side/websocket-support.html#handling-messages не совсем понятен.

Создание маршрута для сервера

  public Route createRoute() {
    return path("subscription", () ->
            get(() ->
                concat(
                    handleWebSocketMessages(subscriptionFlow()))));
  }

  public Flow<Message, Message, NotUsed> subscriptionFlow() {

Я считаю, что вам нужно вернуть поток, который обрабатывал бы входящие / исходящие сообщения. Думая, что для сообщений нет запроса / ответа, а есть только слабое звено, мне понадобится отдельный приемник для запросов и отдельный источник для отправки ответов, хотя приемник все еще должен знать об источнике, чтобы позже он мог знать, кому этот ответ отправлен на адрес.

Я нашел только примеры запроса / ответа или приемник полностью игнорируется и, возможно, один более старый пример https://markatta.com/codemonkey/posts/chat-with-akka-http-websockets-old/

Я думаю использовать Flow.fromSinkAndSourceCoupled и, возможно, иметь актера, который создается для каждого подключения к веб-сокету.

Я не могу реализовать идею Sink.actorRefWithBackpressure, Source.actorRefWithBackpressure, Flow.fromSinkAndSourceCoupled и создания актера для каждого подключения к веб-сокету.

В типизированном актере (в настоящее время 2.6.3) я не могу найти способ создать актера для каждого подключения к веб-сокету, как в старом примере.

val userActor = system.actorOf(Props(new User(chatRoom)))

Есть ли пример в проектах akka / akka-stream / akka-http или где-нибудь еще, где показана эта функция?