Use a shared download scheduler for all network access

1 files changed, 6 insertions, 1 deletions

diff --git a/main/src/cgeo/geocaching/utils/RxUtils.java b/main/src/cgeo/geocaching/utils/RxUtils.java
index b865f0b..241ba78 100644
--- a/main/src/cgeo/geocaching/utils/RxUtils.java
+++ b/main/src/cgeo/geocaching/utils/RxUtils.java
@@ -5,6 +5,10 @@ import rx.Scheduler;
 import rx.observables.BlockingObservable;
 import rx.schedulers.Schedulers;
 
+import java.util.concurrent.LinkedBlockingQueue;
+import java.util.concurrent.ThreadPoolExecutor;
+import java.util.concurrent.TimeUnit;
+
 public class RxUtils {
 
     // Utility class, not to be instanciated
@@ -12,9 +16,10 @@ public class RxUtils {
 
     public final static Scheduler computationScheduler = Schedulers.computation();
 
+    public static final Scheduler networkScheduler = Schedulers.from(new ThreadPoolExecutor(10, 10, 5, TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>()));
+
     public static <T> void waitForCompletion(final BlockingObservable<T> observable) {
         observable.lastOrDefault(null);
-        return;
     }
 
     public static void waitForCompletion(final Observable<?>... observables) {