将现有的WebSocket实现转换为Android Java中的Reactive WebSocket。

Question

我在Android中使用OKHttpClient与WebSockets.我想把它转换成反应式编程，如何实现这一点，目前我正在做这个WebSocket连接。

    // OkHttp Client
    OkHttpClient httpClient = new OkHttpClient.Builder().build();

    // WebSocket Object
    Request request = new Request.Builder().url(url).build();
    mWebSocket = httpClient.newWebSocket(request, new WebSocketListener() {
        // Override methods - OnOpen, OnMessage, OnClosing, OnFailure
    }

    // Then Calling this to make websocket request
    mWebSocket.send(message);

我已经找到了这个库来使用反应式WebSocket。https:/github.comjacek-marchwickiJavaWebsocketClient。

但没有回调监听器作为'WebSocketListener'，所以我可以处理消息。

任何帮助将被感激在这个方向。谢谢你的帮助