Skip to content

Commit

Permalink
.
Browse files Browse the repository at this point in the history
  • Loading branch information
wosojadfjgo committed Sep 3, 2019
1 parent 662cbe3 commit 2908416
Show file tree
Hide file tree
Showing 3 changed files with 21 additions and 3 deletions.
4 changes: 3 additions & 1 deletion app/src/main/java/com/heyongrui/youju/WelcomeActivity.java
Original file line number Diff line number Diff line change
Expand Up @@ -92,7 +92,9 @@ private void loadLocalCover() {//加载本地封面图
private void startMainActivity() {//开始缩放动画
rxManager.add(Observable.timer(1000, TimeUnit.MILLISECONDS)
.observeOn(AndroidSchedulers.mainThread())
.subscribe(aLong -> startAnim()));
.subscribe(aLong -> startAnim(), throwable -> {
throwable.printStackTrace();
}));
}

private void startDownloadCover() {//随机下载封面图
Expand Down
2 changes: 2 additions & 0 deletions base/src/main/java/com/heyongrui/base/rxbus/RxBus.java
Original file line number Diff line number Diff line change
Expand Up @@ -143,6 +143,8 @@ public void accept(RxBusEvent rxBusEvent) throws Exception {
e.printStackTrace();
}
}
}, throwable -> {
throwable.printStackTrace();
});

subscriptions.add(subscription);
Expand Down
18 changes: 16 additions & 2 deletions base/src/main/java/com/heyongrui/base/utils/UpdateCheckUtil.java
Original file line number Diff line number Diff line change
Expand Up @@ -79,8 +79,14 @@ public void checkUpdate(@NonNull String updateCheckUrl, @NonNull String authorit
catLoadingDialog.show();
//构建网络请求
mCompositeDisposable.add(Observable.just(updateCheckUrl).map(requestUrl -> {
Request request = new Request.Builder().url(requestUrl).build();
return client.newCall(request).execute();
Response execute = null;
try {
Request request = new Request.Builder().url(requestUrl).build();
execute = client.newCall(request).execute();
} catch (IOException e) {
e.printStackTrace();
}
return execute;
}).subscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread()).subscribe(response -> {
//网络请求返回结果解析
if (catLoadingDialog != null && catLoadingDialog.isShowing()) {
Expand Down Expand Up @@ -114,8 +120,16 @@ public void checkUpdate(@NonNull String updateCheckUrl, @NonNull String authorit
ToastUtils.showShort(R.string.update_error);
}
} else {
if (catLoadingDialog != null && catLoadingDialog.isShowing()) {
catLoadingDialog.dismiss();
}
ToastUtils.showShort(R.string.update_error);
}
}, throwable -> {
if (catLoadingDialog != null && catLoadingDialog.isShowing()) {
catLoadingDialog.dismiss();
}
ToastUtils.showShort(R.string.update_error);
}));
} catch (Exception e) {
e.printStackTrace();
Expand Down

0 comments on commit 2908416

Please sign in to comment.