fix bug and circle dependence problem

This commit is contained in:
zhongchao
2021-09-01 17:12:12 +08:00
parent 9b41205800
commit cdcfd2eafa
548 changed files with 94 additions and 23784 deletions

View File

@@ -581,7 +581,7 @@ public class MogoADASController implements IMogoADASController {
requestCarModelList(params).
subscribeOn(Schedulers.io()).
observeOn(Schedulers.io()).
subscribe(new SubscribeImpl<CarModelListResponse>(RequestOptions.create(context)) {
subscribe(new SubscribeImplTemporary<CarModelListResponse>(RequestOptions.create(context)) {
@Override
public void onSuccess(CarModelListResponse o) {
super.onSuccess(o);

View File

@@ -0,0 +1,83 @@
package com.mogo.service.impl.adas;
import com.mogo.service.adas.entity.CarModelListResponse;
import com.mogo.utils.logger.Logger;
import com.mogo.utils.network.RequestOptions;
import com.mogo.utils.network.utils.Util;
import io.reactivex.Observer;
import io.reactivex.disposables.Disposable;
/**
* Created by congtaowang on 2018/10/14. //todo 后续干掉!!! 优化adas模块
*/
public abstract class SubscribeImplTemporary<T> implements Observer<T> {
protected final RequestOptions mRequestOptions;
private static final String TAG = "SubscribeImpl";
private boolean mAutoTipMsg = true;
public SubscribeImplTemporary(RequestOptions requestOptions) {
mRequestOptions = requestOptions;
}
public SubscribeImplTemporary(RequestOptions requestOptions, boolean autoTipMsg) {
this(requestOptions);
mAutoTipMsg = autoTipMsg;
}
private void onFinish() {
if (!Util.checkAlive(mRequestOptions.getCaller())) {
}
}
@Override
public void onError(Throwable e) {
onFinish();
Logger.e(TAG, e, "occur when net request.");
}
@Override
public void onNext(T o) {
if (o != null) {
if (o instanceof CarModelListResponse) {
CarModelListResponse response = (CarModelListResponse) o;
if (response.code != 0 && response.code != 200) {
onError(response.msg, response.code);
} else {
onSuccess(o);
}
} else {
onError("", -1);
}
} else {
onError("", -1);
}
}
@Override
public void onSubscribe(Disposable d) {
}
@Override
public void onComplete() {
onFinish();
}
public void onSuccess(T o) {
}
public void onError(String message, int code) {
Logger.e(TAG, "%d - %s", code, message);
}
private static boolean isTicketUpdated = false;
private void onUpdateTicket() {
}
}