Всем привет,

Есть presenter и model, service. Нужно сделать поиск, т.е. при каждом вводе текста делать запрос на сервер и выводить результат, а старый игнорировать.

Архитектурно сделано так, что presenter передает observer в model, модель вызывает service (retrofit), который возвращает observable, далее наша модель делает подписку передавая observer-а презентера.

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

switchMap

Всем привет,

Есть presenter и model, service. Нужно сделать поиск, т.е. при каждом вводе текста делать запрос на сервер и выводить результат, а старый игнорировать.

Архитектурно сделано так, что presenter передает observer в model, модель вызывает service (retrofit), который возвращает observable, далее наша модель делает подписку передавая observer-а презентера.

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

Всем привет,

Есть presenter и model, service. Нужно сделать поиск, т.е. при каждом вводе текста делать запрос на сервер и выводить результат, а старый игнорировать.

Архитектурно сделано так, что presenter передает observer в model, модель вызывает service (retrofit), который возвращает observable, далее наша модель делает подписку передавая observer-а презентера.

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

Обычно такие вещи с поиском делаются при помощи оператора debounce. Почитай про этот оператор.
Можно написать свой текствочер, а можно использовать либу Жени Вартанова (RxViews кажется называется)

debounce не поможет, если запрос улетел и через какое-то время человек снова ввел в поиск что-то и при этом ответ еще не пришел

я вам объяснил максимально часто используемую логику при построении поиска в приложении.
Тогда удачи вам с отправкой интернет запросов на каждый введенный символ :)

Debounce и так используется

Если можно было в презентере все сделать, то было бы ок, но по архитектуре не могу так сделать

Тогда выходит что фича нереализуема, архитектура ж)

А может  все таки есть какие то варианты кроме dispose() у предыдущего observable? :)