2 files changed, 20 insertions, 21 deletions

diff --git a/main/src/cgeo/geocaching/connector/gc/GCParser.java b/main/src/cgeo/geocaching/connector/gc/GCParser.java
index f20df8d..d12ff13 100644
--- a/main/src/cgeo/geocaching/connector/gc/GCParser.java
+++ b/main/src/cgeo/geocaching/connector/gc/GCParser.java
@@ -57,7 +57,6 @@ import rx.functions.Action1;
 import rx.functions.Func0;
 import rx.functions.Func2;
 import rx.schedulers.Schedulers;
-import rx.util.async.Async;
 
 import android.net.Uri;
 import android.text.Html;
@@ -304,12 +303,13 @@ public abstract class GCParser {
 
         if (!cids.isEmpty() && (Settings.isGCPremiumMember() || showCaptcha) && ((recaptchaReceiver == null || StringUtils.isBlank(recaptchaReceiver.getChallenge())) || StringUtils.isNotBlank(recaptchaText))) {
             Log.i("Trying to get .loc for " + cids.size() + " caches");
-            final Observable<Set<Geocache>> storedCaches = Async.start(new Func0<Set<Geocache>>() {
+            final Observable<Set<Geocache>> storedCaches = Observable.defer(new Func0<Observable<Set<Geocache>>>() {
                 @Override
-                public Set<Geocache> call() {
-                    return DataStore.loadCaches(Geocache.getGeocodes(caches), LoadFlags.LOAD_CACHE_OR_DB);
+                public Observable<Set<Geocache>> call() {
+                    return Observable.just(DataStore.loadCaches(Geocache.getGeocodes(caches), LoadFlags.LOAD_CACHE_OR_DB));
                 }
-            }, Schedulers.io());
+            }).subscribeOn(Schedulers.io()).cache();
+            storedCaches.subscribe();  // Force asynchronous start of database loading
 
             try {
                 // get coordinates for parsed caches
@@ -979,22 +979,22 @@ public abstract class GCParser {
      * Observable that fetches a list of pocket queries. Returns a single element (which may be an empty list).
      * Executes on the network scheduler.
      */
-    public static final Observable<List<PocketQueryList>> searchPocketQueryListObservable = Async.fromCallable(new Func0<List<PocketQueryList>>() {
+    public static final Observable<List<PocketQueryList>> searchPocketQueryListObservable = Observable.defer(new Func0<Observable<List<PocketQueryList>>>() {
         @Override
-        public List<PocketQueryList> call() {
+        public Observable<List<PocketQueryList>> call() {
             final Parameters params = new Parameters();
 
             final String page = GCLogin.getInstance().getRequestLogged("http://www.geocaching.com/pocket/default.aspx", params);
 
             if (StringUtils.isBlank(page)) {
                 Log.e("GCParser.searchPocketQueryList: No data from server");
-                return Collections.emptyList();
+                return Observable.just(Collections.<PocketQueryList>emptyList());
             }
 
             final String subPage = StringUtils.substringAfter(page, "class=\"PocketQueryListTable");
             if (StringUtils.isEmpty(subPage)) {
                 Log.e("GCParser.searchPocketQueryList: class \"PocketQueryListTable\" not found on page");
-                return Collections.emptyList();
+                return Observable.just(Collections.<PocketQueryList>emptyList());
             }
 
             final List<PocketQueryList> list = new ArrayList<>();
@@ -1024,9 +1024,9 @@ public abstract class GCParser {
                 }
             });
 
-            return list;
+            return Observable.just(list);
         }
-    }, RxUtils.networkScheduler);
+    }).subscribeOn(RxUtils.networkScheduler);
 
     public static ImmutablePair<StatusCode, String> postLog(final String geocode, final String cacheid, final String[] viewstates,
             final LogType logType, final int year, final int month, final int day,
diff --git a/main/src/cgeo/geocaching/connector/gc/Tile.java b/main/src/cgeo/geocaching/connector/gc/Tile.java
index 93b61f9..18d296d 100644
--- a/main/src/cgeo/geocaching/connector/gc/Tile.java
+++ b/main/src/cgeo/geocaching/connector/gc/Tile.java
@@ -15,7 +15,6 @@ import org.eclipse.jdt.annotation.NonNull;
 
 import rx.Observable;
 import rx.functions.Func0;
-import rx.util.async.Async;
 
 import android.graphics.Bitmap;
 import android.graphics.BitmapFactory;
@@ -241,12 +240,12 @@ public class Tile {
 
     static Observable<String> requestMapInfo(final String url, final Parameters params, final String referer) {
         final HttpResponse response = Network.getRequest(url, params, new Parameters("Referer", referer));
-        return Async.start(new Func0<String>() {
+        return Observable.defer(new Func0<Observable<String>>() {
             @Override
-            public String call() {
-                return Network.getResponseData(response);
+            public Observable<String> call() {
+                return Observable.just(Network.getResponseData(response));
             }
-        }, RxUtils.networkScheduler);
+        }).subscribeOn(RxUtils.networkScheduler);
     }
 
     /** Request .png image for a tile. Return as soon as the request has been made, before the answer has been
@@ -256,17 +255,17 @@ public class Tile {
      */
     static Observable<Bitmap> requestMapTile(final Parameters params) {
         final HttpResponse response = Network.getRequest(GCConstants.URL_MAP_TILE, params, new Parameters("Referer", GCConstants.URL_LIVE_MAP));
-        return Async.start(new Func0<Bitmap>() {
+        return Observable.defer(new Func0<Observable<Bitmap>>() {
             @Override
-            public Bitmap call() {
+            public Observable<Bitmap> call() {
                 try {
-                    return response != null ? BitmapFactory.decodeStream(response.getEntity().getContent()) : null;
+                    return Observable.just(response != null ? BitmapFactory.decodeStream(response.getEntity().getContent()) : null);
                 } catch (final IOException e) {
                     Log.e("Tile.requestMapTile() ", e);
-                    return null;
+                    return Observable.just(null);
                 }
             }
-        }, RxUtils.computationScheduler);
+        }).subscribeOn(RxUtils.computationScheduler);
     }
 
     public boolean containsPoint(final @NonNull ICoordinates point) {