我已将Play Framework版本从2.4.1更新为2.5.6，但现在Web套接字管理出现问题。
我有一个Controller类，其中方法liveUpdate()返回一个WebSocket<String>示例。
在这个方法中，我使用WebSocket.whenReady()，在HashMap<Out<String>, String>中使用Out<String>，其中键是客户端输出流，值是包含语言信息的String，因为当我需要发送广播消息时，我会迭代HashMap。
现在所有这些都在2.5.6中被删除或弃用！
搜索Web时，我发现新的实现基于Akka Streams，使用Flow类，但我不知道如何修改我的代码。

• WebSocket.whenReady()已替换为WebSocket.Text.accept()
• Out<?>被具有Flow类的akka流替换

这是我的代码：

警报.java

public class Alarms extends Controller {

    @Inject
    private ActiveAlarms activeAlarms;

    [...]

    public WebSocket liveUpdate() {

        return WebSocket.whenReady((in, out) -> {

            in.onMessage(language ->{
                activeAlarms.register(out, language);
            });

            in.onClose(() -> activeAlarms.unregister(out));
        });
    }

    [...]
}

活动报警.java

public class ActiveAlarms{

    private HashMap<Out<String>, String> websockets = new HashMap<>();

    [...]

    public void register(Out<String> out, String language) {
        websockets.put(out, language);
        updateWebsockets(out, language);
    }

    public void unregister(Out<String> out) {
        websockets.remove(out);
    }

    private void updateWebsockets(Out<String> s, String lang){

        if(s == null) return;

        List<AlarmEvent> alarmsList = AlarmEvent.findActive();
        ArrayList<AlarmEvent> translatedAlarmsList = new ArrayList<>();

        //translate
        alarmsList.forEach(e ->{
            if(e != null) {

                e.setAlarm(e.getAlarm().translate(checkLanguage(lang)));
                translatedAlarmsList.add(e);
            }
        });

        //WRITE TO SOCKET
        String alarms = Json.stringify(Json.toJson(translatedAlarmsList));
        try {
            s.write(alarms);
        } catch (Exception e2) {
            Logger.debug("EX ActiveAlarms --> updateWebSocket  " + e2.getMessage());
        }
    }

    private void updateWebsockets(){
        websockets.forEach(this::updateWebsockets);
    }

    [...]
}

如何将我的代码转换为WebSocket的新实现？