Собственно вот кусок кода делающий тоже самое - единственное отличие поиск происходит в локальной базе:
https://gist.github.com/RuslanKrohalev/04793083d3e0bd16fb78a473b819dc81
Там интерактор возвращает DataSource.Factory<Int, Item>

Только вот проблема в том что PagedList  не будет пока первый запрос не закончится. Мы же не можем в нем load init сделать асинхронным

сорри что не сразу. Отсутсвовал

с базой у меня то же раотает потому что там этой проблемы не заметно 😉 ответ быстро приходит… А вот как только начал из сети тянуть и тестировать на медленном соединение появились проблемы

В чем именно выражаются проблемы?

ну в том что запустить по нормальному новый зарос не получается пока не закончится первый…я то уже закостылил решение но он мега костыльное. Я добавил в датасурс возможность вызвать interupt для текущего потока

ты мой гист смотрел? что именно тебе мешает запустить новый запрос? там даже предыдущий отменяется

Да но насколько я понимаю у livePagedListBuilder так запрос нельзя оборвать. Можно конечно перепилить на RxPagedListBuilder …

Ты можешь сделать тоже самое с LivePagedListBuilder.  Можно при изменении критерия поиска создать новый билдер и переподписываться на новую LiveData<PagedList>, отписавшись от старой.
Но вариант с RxPagedListBuilder вроде проще

попробую

Попробовал с LivePagedListBuilder… не помогло…точнее частично помогло. Дело в том что когда я отписываюсь от старого LiveData он не обрывает запрос. А поскольку я использую один и
тот же Executor (в моем случае это пул из трех штук), то все равно новые запросы ждут окончания старых (в рамках пула конечно)

Кстати а что такое .connectToSubscriptions() в примере ?

Отписка от LiveData или вызов dispose у Disposable из RX само по себе не прерывает выполнение запроса - мы просто не получим результат по завершению запроса. Тебе прийдется реализовывать прерывание самому.
Например если у тебя используется Retrofit - вызывай call.cancel() в DataSource.
.connectToSubscriptions() - функция в презентере, которая добавляет rx subscription (Disposable) в CompositeDisposable. Это для того чтобы отменить все активные запросы при уходе с экрана / дестрое презентера

private val subscriptions = CompositeDisposable()

override fun onCleared() {
   super.onCleared()
   subscriptions.dispose()
}

protected fun Disposable.connectToSubscriptions(): Disposable {
   subscriptions.add(this)
   return this
}

Retrofit.RxCallAdapter стопает запрос при dispose цепи

Да, я это знаю. Но я не уверен что происходит в RxPagedListBuilder

Посмотрел в RxPagedListBuilder. Там при dispose вызовется метод removeInvalidatedCallback(@NonNull InvalidatedCallback onInvalidatedCallback) у DataSource. То есть автоматом ничего не отменится, только колбэк уберется

ну прерывание я уже до нашего разговора впилил. Просто думал что может это из коробки уже есть

А можно в Room как-то выполнить в транзакци пару запросов каждый из которых возвращает Completable (под запросом я конечно же понимаю метод в DAO) и вернуть результат так же в виже completable ?

Дело в том что сейчас beginTransaction deprecateddeprecated.

можно конечно вкостылить select после транзакции для проверки результата, но это как-то совсем криво