Преобразование существующей реализации WebSocket в Reactive WebSocket в Android Java - PullRequest
Новая
       84

Преобразование существующей реализации WebSocket в Reactive WebSocket в Android Java

0 голосов
/ 08 мая 2020

Я использую OKHttpClient с WebSockets в Android. Я хочу преобразовать это в реактивное программирование. Как этого добиться. На данный момент я делаю это для подключения к 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);

Я обнаружил, что эта библиотека использует Reactive WebSocket https://github.com/jacek-marchwicki/JavaWebsocketClient

Но прослушивателя обратного вызова нет. 'WebSocketListener', чтобы я мог обрабатывать сообщения.

Любая помощь будет оценена в этом направлении. Спасибо

...