simple rxbinding

.md

private void createEditTextSearch() {
    RxTextView.afterTextChangeEvents(placeName)
            .debounce(500, TimeUnit.MILLISECONDS)
            .filter(new Predicate<TextViewAfterTextChangeEvent>() {
                @Override
                public boolean test(TextViewAfterTextChangeEvent textViewAfterTextChangeEvent) throws Exception {
                    return isFocused;
                }
            })
            .filter(new Predicate<TextViewAfterTextChangeEvent>() {
                @Override
                public boolean test(TextViewAfterTextChangeEvent textViewAfterTextChangeEvent) throws Exception {
                    return currentLocation != null;
                }
            })
            .flatMap(new Function<TextViewAfterTextChangeEvent, ObservableSource<? extends PlacesResult>>() {
                @Override
                public ObservableSource<? extends PlacesResult> apply(TextViewAfterTextChangeEvent textViewAfterTextChangeEvent) throws Exception {
                    return placesLoader.find(textViewAfterTextChangeEvent.editable().toString(), currentLocation);
                }
            })
            .subscribeOn(Schedulers.io())
            .observeOn(AndroidSchedulers.mainThread())
            .subscribe(subscriber);
}

Observer<PlacesResult> subscriber = new Observer<PlacesResult>() {
    @Override
    public void onSubscribe(Disposable d) {

    }

    @Override
    public void onNext(PlacesResult placesResult) {
        Log.d("onNext", "");
        refreshRecycleViewData(placesResult);
    }

    @Override
    public void onError(Throwable e) {
        Log.d("onError", e.toString());
        createEditTextSearch();
    }

    @Override
    public void onComplete() {
        Log.d("onComplete", "");
    }
};