CarController.java 文件源码

public void start() {
    mGoogleApiClientRepository.connect();
    mGoogleApiClientRepository.subscribeToThingsMessage(new DisposableObserver<ThingsMessage>() {
        @Override
        public void onNext(ThingsMessage message) {
            handleThingsMessage(message);
        }

        @Override
        public void onError(Throwable e) {
            Timber.e(e);
        }

        @Override
        public void onComplete() {

        }
    });
}