RxAndroid: как добавлять элементы в наблюдатель

Вам нужна подкрепляющая собственность.

private val querySubject:Subject<<String>> = PublishSubject.create()

fun onQueryTextChange(newText: String?): Boolean {
    querySubject.onNext(newText)
    return true
}
fun queryStream:Observable<String>{
   return querySubject
}

Теперь у вас есть функция queryStream, которая выдаст все тексты для поиска и не закроется. И вы можете использовать это так:

val disposable = queryStream.flatMap(model.search(newText))
            .subscribeOn(workerThreadScheduler)
            .observeOn(mainThreadScheduler)
            .subscribe(observer)