public static Observable<String> getSearchObservable(SearchView searchView) {
        return Observable.<String>create(publisher -> {
            final SearchView.OnQueryTextListener listener = new SearchView.OnQueryTextListener() {
                @Override
                public boolean onQueryTextSubmit(String query) {
                    publisher.onNext(query);
                    return true;
                }

                @Override
                public boolean onQueryTextChange(String newText) {
                    publisher.onNext(newText);
                    return true;
                }
            };
            searchView.setOnQueryTextListener(listener);
            publisher.setCancellable(() -> searchView.setOnQueryTextListener(null));
        }).skip(1);
    }