aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorSamuel Tardieu <sam@rfc1149.net>2014-01-26 14:49:34 +0100
committerSamuel Tardieu <sam@rfc1149.net>2014-01-26 15:01:30 +0100
commit5687f16fb1adcf81a045159985b5059f988d8cbb (patch)
tree0476b5cc3035dca53f033f9c4f4f5d45d3988bdc
parent4b2098fbe2c24b423dcf619981d7a9f3faeebb67 (diff)
downloadcgeo-5687f16fb1adcf81a045159985b5059f988d8cbb.zip
cgeo-5687f16fb1adcf81a045159985b5059f988d8cbb.tar.gz
cgeo-5687f16fb1adcf81a045159985b5059f988d8cbb.tar.bz2
refactoring: use Scheduler.schedule for distant action
-rw-r--r--main/src/cgeo/geocaching/utils/GeoDirHandler.java8
1 files changed, 5 insertions, 3 deletions
diff --git a/main/src/cgeo/geocaching/utils/GeoDirHandler.java b/main/src/cgeo/geocaching/utils/GeoDirHandler.java
index e55aede..7cfef89 100644
--- a/main/src/cgeo/geocaching/utils/GeoDirHandler.java
+++ b/main/src/cgeo/geocaching/utils/GeoDirHandler.java
@@ -7,6 +7,8 @@ import cgeo.geocaching.settings.Settings;
import rx.Observable;
import rx.Subscription;
import rx.android.schedulers.AndroidSchedulers;
+import rx.schedulers.Schedulers;
+import rx.util.functions.Action0;
import rx.util.functions.Action1;
import java.util.concurrent.TimeUnit;
@@ -99,12 +101,12 @@ public abstract class GeoDirHandler {
if (geoSubscription != null) {
final Subscription subscription = geoSubscription;
geoSubscription = null;
- Observable.interval(2500, TimeUnit.MILLISECONDS).take(1).subscribe(new Action1<Long>() {
+ Schedulers.newThread().schedule(new Action0() {
@Override
- public void call(final Long aLong) {
+ public void call() {
subscription.unsubscribe();
}
- });
+ }, 2500, TimeUnit.MILLISECONDS);
}
}