Upgraded RxLint (#125)

AdevintaSpain · Nov 28, 2017 · 0531946 · 0531946
1 parent b292293
commit 0531946
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 3 deletions.
diff --git a/leku/build.gradle b/leku/build.gradle
@@ -56,7 +56,7 @@ dependencies {
   implementation "io.reactivex:rxandroid:1.2.1"
   implementation 'io.reactivex.rxjava2:rxjava:2.1.6'
   implementation 'io.reactivex.rxjava2:rxandroid:2.0.1'
-  implementation 'nl.littlerobots.rxlint:rxlint:1.5'
+  implementation 'nl.littlerobots.rxlint:rxlint:1.6'
 
   androidTestImplementation 'com.android.support.test.espresso:espresso-core:3.0.1'
   androidTestImplementation 'com.android.support.test:runner:1.0.1'

diff --git a/leku/src/main/java/com/schibstedspain/leku/geocoder/GeocoderPresenter.java b/leku/src/main/java/com/schibstedspain/leku/geocoder/GeocoderPresenter.java
@@ -7,6 +7,7 @@
 import io.reactivex.android.schedulers.AndroidSchedulers;
 import io.reactivex.disposables.CompositeDisposable;
 import io.reactivex.disposables.Disposable;
+import io.reactivex.schedulers.Schedulers;
 import java.util.concurrent.TimeUnit;
 import pl.charmas.android.reactivelocation2.ReactiveLocationProvider;
 
@@ -73,7 +74,7 @@ public void getFromLocationName(String query, LatLng lowerLeft, LatLng upperRigh
   public void getDebouncedFromLocationName(String query, int debounceTime) {
     view.willLoadLocation();
     Disposable disposable = geocoderRepository.getFromLocationName(query)
-        .debounce(debounceTime, TimeUnit.MILLISECONDS)
+        .debounce(debounceTime, TimeUnit.MILLISECONDS, Schedulers.io())
         .observeOn(scheduler)
         .subscribe(view::showDebouncedLocations, throwable -> view.showLoadLocationError(),
             view::didLoadLocation);
@@ -83,7 +84,7 @@ public void getDebouncedFromLocationName(String query, int debounceTime) {
   public void getDebouncedFromLocationName(String query, LatLng lowerLeft, LatLng upperRight, int debounceTime) {
     view.willLoadLocation();
     Disposable disposable = geocoderRepository.getFromLocationName(query, lowerLeft, upperRight)
-        .debounce(debounceTime, TimeUnit.MILLISECONDS)
+        .debounce(debounceTime, TimeUnit.MILLISECONDS, Schedulers.io())
         .observeOn(scheduler)
         .subscribe(view::showDebouncedLocations, throwable -> view.showLoadLocationError(),
             view::didLoadLocation);