diff options
| author | Samuel Tardieu <sam@rfc1149.net> | 2014-01-26 14:49:34 +0100 |
|---|---|---|
| committer | Samuel Tardieu <sam@rfc1149.net> | 2014-01-26 15:01:30 +0100 |
| commit | 5687f16fb1adcf81a045159985b5059f988d8cbb (patch) | |
| tree | 0476b5cc3035dca53f033f9c4f4f5d45d3988bdc | |
| parent | 4b2098fbe2c24b423dcf619981d7a9f3faeebb67 (diff) | |
| download | cgeo-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.java | 8 |
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); } } |
