RxJava - как реактивно подставлять наблюдаемые значения (в т.ч. пары) в запрос в Room, который так же возвращает Observable?

Во вьюМодели:

val searchQuery = Observable<String>
val catNumberOnlyTurnedoff = Observable<Pair<Int, Boolean>>

fun getWords(query: String, category: Int, onlyOff: Boolean) : LiveData<List<Word>> = 
LiveDataReactiveStreams.fromPublisher(wordDao.getWordsRx(query, category, onlyOff)
.toFlowable(BackpressureStrategy.LATEST))


Запрос в dao выглядит так:

fun getWordsRx(
        query: String,
        category: Int,
        onlyOff: Boolean
    ): Observable<List<Word>> = blablabla

Как лаконичнее сделать чтобы при перемене какого-то из значений в Observabl-ах аргументов они автоматически подставлялись в запрос с соответствующими изменениями в передаваемом в Ливдату списке?


Ответы (0 шт):