yangyakun921/MoGoEagleEye
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge remote-tracking branch 'origin/qa_light' into qa_light

Browse Source
This commit is contained in:
董宏宇
2020-09-17 13:32:35 +08:00
parent 212a8752dd 48a201266b
commit e9459b60ae
1 changed files with 12 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files

27
modules/mogo-module-v2x/src/main/java/com/mogo/module/v2x/network/V2XShareNetworkModel.java
View File

@@ -47,11 +47,6 @@ public class V2XShareNetworkModel {
@Override
public void subscribe(ObservableEmitter<String> emitter) throws Exception {
try {
getShareIndex(callback);
} catch (Exception e) {
e.printStackTrace();
}
emitter.onNext("1");
emitter.onComplete();
}
@@ -60,16 +55,10 @@ public class V2XShareNetworkModel {
Observable<String> listObservable = Observable.create(new ObservableOnSubscribe<String>() {
@Override
public void subscribe(ObservableEmitter<String> emitter) throws Exception {
try {
getShareEventList(page, size, callback);
} catch (Exception e) {
e.printStackTrace();
}
emitter.onNext("2");
emitter.onComplete();
}
});
indexObservable.flatMap(new Function<String, ObservableSource<?>>() {
@Override
public ObservableSource<?> apply(String s) throws Exception {
@@ -82,12 +71,20 @@ public class V2XShareNetworkModel {
@Override
public void onSubscribe(Disposable d) {
try {
getShareIndex(callback);
} catch (Exception e) {
e.printStackTrace();
}
}
@Override
public void onNext(Object o) {
try {
getShareEventList(page, size, callback);
} catch (Exception e) {
e.printStackTrace();
}
}
@Override
@@ -135,7 +132,7 @@ public class V2XShareNetworkModel {
@Override
public void onError(Throwable e) {
super.onError(e);
if (callback != null){
if (callback != null) {
callback.onFail("网络异常，点击刷新重试");
}
}
@@ -179,7 +176,7 @@ public class V2XShareNetworkModel {
@Override
public void onError(Throwable e) {
super.onError(e);
if (callback != null){
if (callback != null) {
callback.onFail("网络异常，点击刷新重试");
}
}