diff options
| author | Samuel Tardieu <sam@rfc1149.net> | 2014-11-07 17:27:59 +0100 |
|---|---|---|
| committer | Samuel Tardieu <sam@rfc1149.net> | 2014-11-07 17:29:42 +0100 |
| commit | 39610f3954517fcf5f6f3442b8779aaede20d4a1 (patch) | |
| tree | 91f2f11fc7733b5e7f936d72937ba5f78d60f50e /main/src | |
| parent | 8b5f55ccc41ba9bc99f9c61f903dcb8ac3a17c04 (diff) | |
| download | cgeo-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.java | 7 |
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(); + }); } } } |
