diff --git a/modules/mogo-module-v2x/src/main/java/com/mogo/module/v2x/network/V2XShareNetworkModel.java b/modules/mogo-module-v2x/src/main/java/com/mogo/module/v2x/network/V2XShareNetworkModel.java index c706acbe91..8d6bb0e529 100644 --- a/modules/mogo-module-v2x/src/main/java/com/mogo/module/v2x/network/V2XShareNetworkModel.java +++ b/modules/mogo-module-v2x/src/main/java/com/mogo/module/v2x/network/V2XShareNetworkModel.java @@ -47,11 +47,6 @@ public class V2XShareNetworkModel { @Override public void subscribe(ObservableEmitter emitter) throws Exception { - try { - getShareIndex(callback); - } catch (Exception e) { - e.printStackTrace(); - } emitter.onNext("1"); emitter.onComplete(); } @@ -60,16 +55,10 @@ public class V2XShareNetworkModel { Observable listObservable = Observable.create(new ObservableOnSubscribe() { @Override public void subscribe(ObservableEmitter emitter) throws Exception { - try { - getShareEventList(page, size, callback); - } catch (Exception e) { - e.printStackTrace(); - } emitter.onNext("2"); emitter.onComplete(); } }); - indexObservable.flatMap(new Function>() { @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("网络异常,点击刷新重试"); } }