aboutsummaryrefslogtreecommitdiffstats
path: root/main/src/cgeo/geocaching/loaders/OwnerGeocacheListLoader.java
diff options
context:
space:
mode:
Diffstat (limited to 'main/src/cgeo/geocaching/loaders/OwnerGeocacheListLoader.java')
-rw-r--r--main/src/cgeo/geocaching/loaders/OwnerGeocacheListLoader.java15
1 files changed, 7 insertions, 8 deletions
diff --git a/main/src/cgeo/geocaching/loaders/OwnerGeocacheListLoader.java b/main/src/cgeo/geocaching/loaders/OwnerGeocacheListLoader.java
index 4d530fb..70db74c 100644
--- a/main/src/cgeo/geocaching/loaders/OwnerGeocacheListLoader.java
+++ b/main/src/cgeo/geocaching/loaders/OwnerGeocacheListLoader.java
@@ -5,6 +5,7 @@ import cgeo.geocaching.connector.ConnectorFactory;
import cgeo.geocaching.connector.capability.ISearchByOwner;
import org.eclipse.jdt.annotation.NonNull;
+import rx.functions.Func1;
import android.content.Context;
@@ -19,15 +20,13 @@ public class OwnerGeocacheListLoader extends AbstractSearchLoader {
@Override
public SearchResult runSearch() {
- SearchResult searchResult = new SearchResult();
-
- for (ISearchByOwner connector : ConnectorFactory.getSearchByOwnerConnectors()) {
- if (connector.isActive()) {
- searchResult.addSearchResult(connector.searchByOwner(username, this));
+ return SearchResult.parallelCombineActive(ConnectorFactory.getSearchByOwnerConnectors(),
+ new Func1<ISearchByOwner, SearchResult>() {
+ @Override
+ public SearchResult call(final ISearchByOwner connector) {
+ return connector.searchByOwner(username, OwnerGeocacheListLoader.this);
}
- }
-
- return searchResult;
+ });
}
}