Replace throttleLast() with distinctUntilChanged().debounce() in Search

Author: rock3r

app/src/main/java/net/squanchy/search/SearchActivity.kt

@@ -72,7 +72,8 @@ class SearchActivity : AppCompatActivity(), SearchRecyclerView.OnSearchResultCli
         searchTextWatcher = SearchTextWatcher(querySubject)
         searchField.addTextChangedListener(searchTextWatcher)
 
-        val searchSubscription = querySubject.throttleLast(QUERY_DEBOUNCE_TIMEOUT, TimeUnit.MILLISECONDS)
+        val searchSubscription = querySubject.distinctUntilChanged()
+            .debounce(QUERY_DEBOUNCE_TIMEOUT, TimeUnit.MILLISECONDS)
             .doOnNext(::updateSearchActionIcon)
             .startWith(getInitialQuery())
             .flatMap(searchService::find)

app/src/main/java/net/squanchy/search/SearchService.kt

@@ -3,16 +3,16 @@ package net.squanchy.search
 import io.reactivex.Observable
 import io.reactivex.functions.Function3
 import net.squanchy.schedule.domain.view.Event
+import net.squanchy.search.SearchListElement.AlgoliaLogo
+import net.squanchy.search.SearchListElement.EventElement
+import net.squanchy.search.SearchListElement.EventHeader
+import net.squanchy.search.SearchListElement.SpeakerElement
+import net.squanchy.search.SearchListElement.SpeakerHeader
 import net.squanchy.search.algolia.AlgoliaSearchEngine
 import net.squanchy.search.algolia.model.AlgoliaSearchResult
-import net.squanchy.search.algolia.model.AlgoliaSearchResult.QueryNotLongEnough
 import net.squanchy.search.algolia.model.AlgoliaSearchResult.ErrorSearching
 import net.squanchy.search.algolia.model.AlgoliaSearchResult.Matches
-import net.squanchy.search.SearchListElement.SpeakerHeader
-import net.squanchy.search.SearchListElement.EventHeader
-import net.squanchy.search.SearchListElement.SpeakerElement
-import net.squanchy.search.SearchListElement.AlgoliaLogo
-import net.squanchy.search.SearchListElement.EventElement
+import net.squanchy.search.algolia.model.AlgoliaSearchResult.QueryNotLongEnough
 import net.squanchy.service.repository.AuthService
 import net.squanchy.service.repository.EventRepository
 import net.squanchy.service.repository.SpeakerRepository