in app/src/main/java/org/apache/taverna/mobile/ui/workflow/WorkflowPresenter.java [103:129]
public void attachSearchHandler(final SearchView searchView) {
checkViewAttached();
compositeDisposable.add(RxSearch.fromSearchView(searchView)
.distinctUntilChanged()
.debounce(300, TimeUnit.MILLISECONDS)
.observeOn(AndroidSchedulers.mainThread())
.subscribeOn(Schedulers.io())
.subscribeWith(new DisposableObserver<String>() {
@Override
public void onNext(String searchText) {
getMvpView().performSearch(searchText);
if (!TextUtils.isEmpty(searchText)) {
searchWorkflow(1, searchText);
}
}
@Override
public void onError(Throwable e) {
}
@Override
public void onComplete() {
}
}));
}