SearchFragment.java

        t.search(query) // Retrofit
                .subscribeOn(Schedulers.io())
                .retry(3)
                .observeOn(Schedulers.io())
                .subscribe(new Observer<List<SearchResult>>() {
                    @Override
                    public void onCompleted() {
                    }

                    @Override
                    public void onError(Throwable e) {
                        Timber.e(e, "onError");
                    }

                    @Override
                    public void onNext(List<SearchResult> searchResults) {
                        ContentValues[] values = insertSearchResults(searchResults);
                        mResultObservable.onNext(values);
                    }
                });

        mResultObservable
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(new Action1<ContentValues[]>() {
                    @Override
                    public void call(ContentValues[] contentValues) {
                        getActivity().... //!
                    }
                });