Advertisement
Guest User

Untitled

a guest
Feb 10th, 2016
47
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 1.02 KB | None | 0 0
  1. mTextWatchSubscription = mSearchResultsSubject
  2. .debounce(400, TimeUnit.MILLISECONDS)
  3. .observeOn(Schedulers.io())
  4. .map(new Func1<String, List<String>>() {
  5.  
  6. @Override
  7. public List<String> call(String s) {
  8. return mRestClient.searchForCity(s);
  9. }
  10. })
  11. .observeOn(AndroidSchedulers.mainThread())
  12. .subscribe(new Observer<List<String>>() {
  13.  
  14. @Override
  15. public void onCompleted() { }
  16.  
  17. @Override
  18. public void onError(Throwable e) { }
  19.  
  20. @Override
  21. public void onNext(List<String> cities) {
  22. handleSearchResults(cities);
  23. }
  24. });
  25.  
  26. mSearchInput.addTextChangedListener(new TextWatcher() {
  27.  
  28. @Override
  29. public void beforeTextChanged(CharSequence s, int start, int count, int after) { }
  30.  
  31. @Override
  32. public void onTextChanged(CharSequence s, int start, int before, int count) {
  33. mSearchResultsSubject.onNext(s.toString());
  34. }
  35.  
  36. @Override
  37. public void afterTextChanged(Editable s) { }
  38. });
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement