2

プロトコル WebSocket を使用してサーバーと通信する Android アプリを開発しています。AsyncAndroid ライブラリを使用します。WebSocket には、サーバーからデータを受信するリスナーがあります。

このようなもの

private WebSocket.StringCallback mStringCallback = new WebSocket.StringCallback() {
        @Override
        public void onStringAvailable(String s) {

        }
    };

私はこのAPIを書く必要があり、rxjavaを使いたいです。しかし、私は想像できません.Observableであり、Observerである必要があります。サーバーから受信したObservable文字列をWebSocketリスナーに入れようとしましたが、それは悪い考えだと思います。APIを正しく構築する方法はありますか。ありがとう。

4

1 に答える 1

1

WebSocket次のように新しいインターフェイスにラップできます。

interface RxWebSocket {
    void send(byte[]); // send data
    Observable<String> stringObservable(); // receive string data
}

次に、実装で、内部で使用して文字列を公開RxWebSocketできます。PublishSubjectWebSocket.StringCallback

于 2016-04-23T11:04:17.200 に答える