From e4b5fb28b996383736fed065b94348645bde8d3d Mon Sep 17 00:00:00 2001
From: Samuel Tardieu <sam@rfc1149.net>
Date: Thu, 29 May 2014 12:39:18 +0200
Subject: Add more parallelism in static maps downloads

---
 main/src/cgeo/geocaching/utils/RxUtils.java | 11 +++++++++++
 1 file changed, 11 insertions(+)

(limited to 'main/src/cgeo/geocaching/utils/RxUtils.java')

diff --git a/main/src/cgeo/geocaching/utils/RxUtils.java b/main/src/cgeo/geocaching/utils/RxUtils.java
index deba573..a5cdc5f 100644
--- a/main/src/cgeo/geocaching/utils/RxUtils.java
+++ b/main/src/cgeo/geocaching/utils/RxUtils.java
@@ -1,6 +1,8 @@
 package cgeo.geocaching.utils;
 
+import rx.Observable;
 import rx.Scheduler;
+import rx.observables.BlockingObservable;
 import rx.schedulers.Schedulers;
 
 public class RxUtils {
@@ -9,4 +11,13 @@ public class RxUtils {
     private RxUtils() {}
 
     public final static Scheduler computationScheduler = Schedulers.computation();
+
+    public static <T> void waitForCompletion(final BlockingObservable<T> observable) {
+        observable.lastOrDefault(null);
+        return;
+    }
+
+    public static void waitForCompletion(final Observable<?>... observables) {
+        waitForCompletion(Observable.merge(observables).toBlockingObservable());
+    }
 }
-- 
cgit v1.1