diff options
Diffstat (limited to 'main')
| -rw-r--r-- | main/src/cgeo/geocaching/CacheListActivity.java | 2 | ||||
| -rw-r--r-- | main/src/cgeo/geocaching/utils/RxUtils.java | 2 |
2 files changed, 3 insertions, 1 deletions
diff --git a/main/src/cgeo/geocaching/CacheListActivity.java b/main/src/cgeo/geocaching/CacheListActivity.java index d1c56b8..d54a6b8 100644 --- a/main/src/cgeo/geocaching/CacheListActivity.java +++ b/main/src/cgeo/geocaching/CacheListActivity.java @@ -1207,7 +1207,7 @@ public class CacheListActivity extends AbstractListActivity implements FilteredA handler.obtainMessage(DownloadProgress.MSG_LOADED, cache).sendToTarget(); subscriber.onCompleted(); } - }).subscribeOn(RxUtils.networkScheduler); + }).subscribeOn(RxUtils.refreshScheduler); } }).doOnCompleted(new Action0() { @Override diff --git a/main/src/cgeo/geocaching/utils/RxUtils.java b/main/src/cgeo/geocaching/utils/RxUtils.java index ec8f7b8..72e7630 100644 --- a/main/src/cgeo/geocaching/utils/RxUtils.java +++ b/main/src/cgeo/geocaching/utils/RxUtils.java @@ -38,6 +38,8 @@ public class RxUtils { public static final Scheduler networkScheduler = Schedulers.from(new ThreadPoolExecutor(10, 10, 5, TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>())); + public static final Scheduler refreshScheduler = Schedulers.from(new ThreadPoolExecutor(3, 3, 5, TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>())); + private static final HandlerThread looperCallbacksThread = new HandlerThread("Looper callbacks thread", Process.THREAD_PRIORITY_DEFAULT); |