diff options
Diffstat (limited to 'main/src/cgeo/geocaching/utils/RxUtils.java')
| -rw-r--r-- | main/src/cgeo/geocaching/utils/RxUtils.java | 7 |
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) { |
