pull/5/head
fengyuecanzhu 4 years ago
parent f06a47797e
commit abe39c5eb9
  1. 4
      app/src/main/java/xyz/fycz/myreader/application/App.java
  2. 3
      app/src/main/java/xyz/fycz/myreader/ui/activity/ReadActivity.java
  3. 3
      app/src/main/java/xyz/fycz/myreader/ui/presenter/BookcasePresenter.java

@ -513,4 +513,8 @@ public class App extends Application {
public static boolean isDebug() { public static boolean isDebug() {
return debug; return debug;
} }
public ExecutorService getmFixedThreadPool() {
return mFixedThreadPool;
}
} }

@ -47,6 +47,8 @@ import java.util.List;
import java.util.Locale; import java.util.Locale;
import io.reactivex.Observable; import io.reactivex.Observable;
import io.reactivex.internal.schedulers.ExecutorScheduler;
import io.reactivex.schedulers.Schedulers;
import xyz.fycz.myreader.ActivityManage; import xyz.fycz.myreader.ActivityManage;
import xyz.fycz.myreader.R; import xyz.fycz.myreader.R;
import xyz.fycz.myreader.application.App; import xyz.fycz.myreader.application.App;
@ -1587,6 +1589,7 @@ public class ReadActivity extends BaseActivity implements ColorPickerDialogListe
chapter.setId(mBook.getId()); chapter.setId(mBook.getId());
} }
CommonApi.getChapterContent(chapter.getUrl(), mReadCrawler) CommonApi.getChapterContent(chapter.getUrl(), mReadCrawler)
.subscribeOn(Schedulers.from(App.getApplication().getmFixedThreadPool()))
.subscribe(new MyObserver<String>() { .subscribe(new MyObserver<String>() {
@Override @Override
public void onNext(@NotNull String s) { public void onNext(@NotNull String s) {

@ -29,6 +29,7 @@ import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors; import java.util.concurrent.Executors;
import io.reactivex.Observable; import io.reactivex.Observable;
import io.reactivex.schedulers.Schedulers;
import xyz.fycz.myreader.R; import xyz.fycz.myreader.R;
import xyz.fycz.myreader.application.App; import xyz.fycz.myreader.application.App;
import xyz.fycz.myreader.application.SysManager; import xyz.fycz.myreader.application.SysManager;
@ -788,7 +789,7 @@ public class BookcasePresenter implements BasePresenter {
mChapterService.saveOrUpdateChapter(chapter, s); mChapterService.saveOrUpdateChapter(chapter, s);
successCathe++; successCathe++;
curCacheChapterNum++; curCacheChapterNum++;
})).subscribe(new MyObserver<Object>() { })).subscribeOn(Schedulers.from(App.getApplication().getmFixedThreadPool())).subscribe(new MyObserver<Object>() {
@Override @Override
public void onNext(@NotNull Object o) { public void onNext(@NotNull Object o) {

Loading…
Cancel
Save