SearchPresenter.kt

override fun search(subject: PublishSubject<String>) {
        compositeDisposable.add(
            subject
                .debounce(300, TimeUnit.MILLISECONDS)
                .filter(Predicate { it: String ->
                    return@Predicate it.isNotEmpty()
                })
                .distinctUntilChanged()
                .switchMap(Function<String, ObservableSource<Recipes>> { it ->
                    query = it
                    return@Function dataManager.searchRecipes(
                        Config.API_KEY,
                        it,
                        "1"
                    )
                        .subscribeOn(Schedulers.io())
                        .observeOn(AndroidSchedulers.mainThread())
                })
                .subscribe({ recipes ->
                    if (!isViewAttached())
                        return@subscribe
                    if (recipes.recipes != null) {
                        mvpView?.refreshSearchList(recipes.recipes!!)
                        page = 2
                    }
                }, { throwable ->
                    if (!isViewAttached())
                        return@subscribe
                    mvpView?.showMessage(throwable.message!!)
                    Timber.e(throwable.message)
                })
        )
    }