aboutsummaryrefslogtreecommitdiffstats
path: root/main/src
diff options
context:
space:
mode:
authorSamuel Tardieu <sam@rfc1149.net>2014-11-07 17:27:59 +0100
committerSamuel Tardieu <sam@rfc1149.net>2014-11-07 17:29:42 +0100
commit39610f3954517fcf5f6f3442b8779aaede20d4a1 (patch)
tree91f2f11fc7733b5e7f936d72937ba5f78d60f50e /main/src
parent8b5f55ccc41ba9bc99f9c61f903dcb8ac3a17c04 (diff)
downloadcgeo-39610f3954517fcf5f6f3442b8779aaede20d4a1.zip
cgeo-39610f3954517fcf5f6f3442b8779aaede20d4a1.tar.gz
cgeo-39610f3954517fcf5f6f3442b8779aaede20d4a1.tar.bz2
Use network scheduler instead of threads to log in
This enforces the limit of concurrent connections.
Diffstat (limited to 'main/src')
-rw-r--r--main/src/cgeo/geocaching/MainActivity.java7
1 files changed, 4 insertions, 3 deletions
diff --git a/main/src/cgeo/geocaching/MainActivity.java b/main/src/cgeo/geocaching/MainActivity.java
index d6f9c73..460d372 100644
--- a/main/src/cgeo/geocaching/MainActivity.java
+++ b/main/src/cgeo/geocaching/MainActivity.java
@@ -39,6 +39,7 @@ import rx.Observable.OnSubscribe;
import rx.Subscriber;
import rx.android.observables.AndroidObservable;
import rx.android.schedulers.AndroidSchedulers;
+import rx.functions.Action0;
import rx.functions.Action1;
import android.app.AlertDialog;
@@ -227,9 +228,9 @@ public class MainActivity extends AbstractActionBarActivity {
for (final ILogin conn : ConnectorFactory.getActiveLiveConnectors()) {
if (mustLogin || !conn.isLoggedIn()) {
- new Thread() {
+ RxUtils.networkScheduler.createWorker().schedule(new Action0() {
@Override
- public void run() {
+ public void call() {
if (mustLogin) {
// Properly log out from geocaching.com
conn.logout();
@@ -237,7 +238,7 @@ public class MainActivity extends AbstractActionBarActivity {
conn.login(firstLoginHandler, MainActivity.this);
updateUserInfoHandler.sendEmptyMessage(-1);
}
- }.start();
+ });
}
}
}