scarlet_implement.kt

        service.observeWebSocketEvent()
            .filter{ it is WebSocket.Event.OnConnectionOpened<*>}
            .subscribe ({ service.sendSubscribe(Subscribe()) },
                {error -> error.printStackTrace()})

        service.observeResponse()
            .subscribeOn(Schedulers.io())
            .subscribe({
                response.postValue(it)
            }, {error -> error.printStackTrace()})