umpteenthdev Dec 22 2017 at 03:17

Реализация поиска с использованием RxJava

4 min

20K

Java*Development for Android*

Tutorial

Translation

Comments 13

ConstOrVar Dec 22 2017 at 12:20

Спасибо за статью. В Вашем примере Observable для SearchView будет не совсем корректно работать. Вы на него подписываетесь в onCreate(), но при срабатывании onQueryTextSubmit у Вас произойдет отписка, так как вызовется onComplete. Получается, что повторный поиск не будет работать. Чтобы повторный поиск работал, нужно избавиться от subject.onComplete();

umpteenthdev Dec 22 2017 at 13:14

Спасибо за замечание. Согласен с этим, добавил информацию в статью.

BFS Dec 22 2017 at 23:45

В целом, использование subject может вести к неочевидным проблемам. Для создания я бы порекомендовал росмотреть на Observable.create, тем более, что там есть emitter, которому можно установить действие при завершении (полезно чтобы снять TextWatcher) например. Здесь, впрочем, появится нюанс: нужно будет правильно переключить потоки, чтобы тело create выполнилось на главном потоке.

umpteenthdev Dec 23 2017 at 05:21

Это перевод статьи, поэтому правки я не вносил в содержание. Но хотелось бы понять о каких конкретно возможных неочевидных проблемах идет речь?

Scrobot Dec 23 2017 at 06:19

Присоеднюсь к BFS, не стоит использовать Subject, он существует только для 1 цели: соединять императивный стиль с реактивным. По сути, он только для легаси подходит. Поэтому, да, лучше Observable.create(). Для подробностей посмотрите доклад Матвея Малькова — Art Of Rx, учитывая что вы андроид разработчик, вам это будет полезно)
И второй момент, поиск это ровно тот кейс, когда нужно думать о Backpressure, а поскольку практически все сегодня используют Rx2, то там эта проблема решена с помощью Flowable, и лучше этот кейс зарефакторить на него.

umpteenthdev Dec 23 2017 at 08:02

Спасибо за рекомендацию доклада. Добавлю ваше замечание к статье.

dmlukas Dec 24 2017 at 01:29

Спасибо, отличная статья, а еще лучше комментарии ).

kpcb Dec 24 2017 at 07:36

Не являюсь android-разработчиком, но по-моему из-за subscribeOn(Schedulers.io()) установка listener-а на поле ввода будет происходить не в главном потоке

umpteenthdev Dec 24 2017 at 07:45

Насколько я знаю, subscribeOn() указывает в какой поток наблюдаемый источник (в нашем случае subject внутри listener поля ввода) будет передавать создаваемые observable элементы. То есть событие происходит в UI потоке, затем его отлавливает listener в этом же потоке, далее subject внутри listener создаёт событие (onNext()), а возвращаемый observable элемент уже попадает в поток IO.

HotIceCream Dec 25 2017 at 00:33

Мне почему-то кажется что прав kpcb.
subscribeOn указывает поток в котором будет происходить подписка. И во время подписки вы создаете слушатель.
Слушатель в UI потоке будет дергать subject.onNext(). и возвращаемый observable будет тоже получать событие в UI потоке.
Но дальше у вас идет метод debounce. Это особенный метод, который возвращает observable, события которого будут производиться в computation sheduler. (Scheduler можно изменить — посмотрите перегрузку метода debounce).

umpteenthdev Dec 25 2017 at 09:06

Проверил. Subject.onNext() отрабатывает в UI потоке, а Debounce() уже в Computation. Спасибо за внимательность.

vba Dec 26 2017 at 13:46

Скажите а вам не надоело пользоваться анонимными классами? На дворе вроде конец 2017 и даже андроид уже более или менее из коробки поддерживает ламбда функции.

umpteenthdev Dec 26 2017 at 14:55

Я бы тоже воспользовался лямбдами и/или ссылками на методы, а использование if для возврата булево значения — бредовая идея. Но это перевод и поэтому я не стал лезть в пример кода автора оригинала.