Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- mTextWatchSubscription = mSearchResultsSubject
- .debounce(400, TimeUnit.MILLISECONDS)
- .observeOn(Schedulers.io())
- .map(new Func1<String, List<String>>() {
- @Override
- public List<String> call(String s) {
- return mRestClient.searchForCity(s);
- }
- })
- .observeOn(AndroidSchedulers.mainThread())
- .subscribe(new Observer<List<String>>() {
- @Override
- public void onCompleted() { }
- @Override
- public void onError(Throwable e) { }
- @Override
- public void onNext(List<String> cities) {
- handleSearchResults(cities);
- }
- });
- mSearchInput.addTextChangedListener(new TextWatcher() {
- @Override
- public void beforeTextChanged(CharSequence s, int start, int count, int after) { }
- @Override
- public void onTextChanged(CharSequence s, int start, int before, int count) {
- mSearchResultsSubject.onNext(s.toString());
- }
- @Override
- public void afterTextChanged(Editable s) { }
- });
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement