RxJavaLibrary

    NetRequestSubscriber<BaseResult> subscriber = new NetRequestSubscriber<>(new NetRequestCallback<BaseResult>() {
        @Override
        public void onStart() {

        }

        @Override
        public void onSuccess(@NonNull BaseResult mResults) {

        }

        @Override
        public void onResultNull() {

        }

        @Override
        public void onError(Throwable throwable) {

        }

        @Override
        public void onCancel() {
            super.onCancel();

        }

        @Override
        public void onFinish() {
            super.onFinish();

        }
    }, this, true, "ssss");
    Observable<BaseResult> observable = RequestServiceUtil.
            createService(ApiEngine.class, PubParameters.URL_INTERFACE_DD)
            .setDevice();
    RequestSender.sendRequest(this, subscriber, observable);