RXJava как скомбинировать два Observable так что бы один прерывал другой?

@arvalon · Регистрация: 26.10.2012

Author24 — интернет-сервис помощи студентам

Доброго для.
Есть задача. Имеем EditText, необходимо получать из него вводимые значения по нажатию кнопки Enter (Go) на клавиатуре ИЛИ по истечении определённого времени. Если нажатие по клавиатуре было произведено до истечения таймаута - отбрасывать дублирующую отправку введённого текста. Сделать Observable для каждой отдельной комбинации получилось, но соединить всё вместе не удаётся.

Итак, имеется EditText:

Кликните здесь для просмотра всего текста

Java
1
2
3
EditText ed = findViewById(R.id.edit_text);
ed.setImeOptions(EditorInfo.IME_ACTION_GO);
ed.setInputType(EditorInfo.IME_ACTION_GO);

Observable, выпускающий события нажатия на Go:

Java
1
2
3
Observable<CharSequence> editorActionObservable = RxTextView.editorActionEvents(ed)
                .filter(predicate)
                .map(event -> ed.getText());

Функция-предикат, пропускающая только нажатия на Go на экранной клавиатуре или Enter на аппаратной (если она есть, это условие задачи), переданная в фильтр Observable'выше

Java
1
2
3
4
Predicate<TextViewEditorActionEvent> predicate = (event ->
                event.actionId() == EditorInfo.IME_ACTION_GO
                || (event.keyEvent().getKeyCode() == KeyEvent.KEYCODE_ENTER
                && event.keyEvent().getAction() == KeyEvent.ACTION_UP ));

Второй Observable, основанный на изменениях текста в текстовом поле и выпускающий события с таймаутом, объединяется с первым Observable'ом Action-событий GO с помощью mergeWith(editorActionObservable).

Java
1
2
3
4
5
6
Disposable textChangedEvent =  RxTextView.textChanges(ed)
                .debounce(2, TimeUnit.SECONDS)
                .filter(text -> text.length() > 2)
                .mergeWith(editorActionObservable)
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(charSequence -> Log.d("LOGTAG", "Search string "+charSequence));

Соответственно получается так что если ввести текст, удовлетворяющий всем условиям второго Observable (textChangedEvent) а потом нажать Go - событие в подписчик приходит дважды - сначала по Go а потом по Timeout'ту. А можно как-то сделать так что событие нажатия клавиатуры сбрасывало/подавляло то что отложено (остановленное в .debounce(2, TimeUnit.SECONDS))? Среди более сотни операторов так и не могу подобрать подходящую комбинацию. Ещё пробовал amb но этот оператор один раз делает выбор между из всех Observable тот который первый испустил событие и отбрасывает все остальные, такое поведение не то что нужно.
Знатоки RXJava, подскажите как быть?

@ExFau$t · 13.09.2019, 16:05

Попробуй этот https://rxmarbles.com/#race

@arvalon · 13.09.2019, 16:17 **[ТС]**

Сообщение от ExFau$t

Попробуй этот https://rxmarbles.com/#race

Хм, не могу найти такой оператор в RXJava, кажется он есть только в RxJS?

@ExFau$t · 13.09.2019, 16:26

А, ну значит этот: http://reactivex.io/documentat... s/amb.html
Не понял, что тут не подходит.

@arvalon · 13.09.2019, 16:34 **[ТС]**

Сообщение от ExFau$t

А, ну значит этот: http://reactivex.io/documentat... s/amb.html
Не понял, что тут не подходит.

C amb получается так что на этом операторе один раз на всё время подписки выбирается Observable, первым выпустивший событие. Второй игнорируется всё время. А нужно что бы последующий и ввод текста и клики по Go совместно работали и выпускалось событие прошедшее все фильтры первым.

@ExFau$t · 13.09.2019, 16:49

Ну случилось событие начала ввода, слушаем кнопку или ждём 2 секунды, дождались чего-то - выполнился поток и всё. Можно хоть 100 раз повторять, что не так?

@arvalon · 13.09.2019, 16:53 **[ТС]**

Сообщение от ExFau$t

слушаем кнопку или ждём 2 секунды

Вот, вот в этой фразе похоже что вся загвоздка. Описать это в терминах rx-цепочек не удаётся. Если ввести текст и успеть нажать кнопку до истечения 2 секунд - два события приходят в подписчик. А хотелось бы одно, которое запустилось нажатием кнопки.

Новые блоги и статьи Все статьи Все блоги /
Winforstrap или красявый дизайн своими руками на HTML+JS+Winforms anomal6 04.03.2025 Сидел тут вечером ковырял проект на MAUI, и как же глупо создаются пакеты MSIX и система обновлений пакета публикации, но не об этом. Бывает нужен современный дизайн программы а писать на MAUI,. . .	Формат данных для симуляции физики, посредством распространённых не обученных моделей. Hrethgir 04.03.2025 Что-то как-то снова потерялось, зато катангенсы закатангесились в одном сообщении. На днях писал, что планирую для работы апгрейдить (на этот раз удачно) девайс для работы (конкретно - здоровья для,. . .	Концепция variadic CoderHuligan 04.03.2025 Мне не очень нравится (а кому это нравится?) что у нас есть отдельно компилятор, отдельно линковщик, причем со своим собственным командным языком. При этом усложнении надо знать помимо языка. . .	Java Record или Kotlin Data Class: что лучше для неизменяемых данных Wired 04.03.2025 Java Record и Kotlin Data Class — два мощных инструмента для обуздания неизменяемых структур данных, каждый со своим уникальным подходом к решению этой задачи. История их появления весьма. . .	Создание производительных API с Java и gRPC Wired 04.03.2025 В мире микросервисной разработки вопрос производительности часто становится краеугольным камнем. И хотя REST API давно завоевал сердца разработчиков своей простотой и интуитивностью, при высоких. . .
Что нового в JDK 24 Wired 04.03.2025 JDK 24 — это настоящий прорыв в эволюции Java, который кардинально меняет правила игры. В этом релизе разработчики Oracle наконец-то довели до ума множество критически важных улучшений в. . .	Разработка блокчейн с использованием Java: смарт-контракты и dApp Wired 04.03.2025 Погружаясь в мир блокчейн-разработки на Java, разработчик получает доступ к внушительному арсеналу инструментов. В отличие от Solidity, который "заперт" в экосистеме Ethereum, Java предоставляет. . .	WebAssembly в Kubernetes stackOverflow 03.03.2025 В современной экосистеме облачных технологий WebAssembly (Wasm) становится все более значимым компонентом, предлагая уникальный подход к выполнению кода в распределенных системах. Эта технология. . .	GitHub Actions или Jenkins: Выбираем CI/CD платформу stackOverflow 03.03.2025 Непрерывная интеграция и развертывание (CI/ CD) изменили подход к разработке программного обеспечения, превратив его в бесшовный процесс от написания кода до развертывания в продакшн. GitHub Actions и. . .	Автоматизация тестирования Pull Request в Kubernetes: Интеграция с GitHub Actions и GKE stackOverflow 03.03.2025 Масштабные проекты с использованием Kubernetes требуют надежной системы тестирования изменений перед их внедрением в продакшн-среду. Традиционный подход с ручной проверкой Pull Request не справляется. . .

@ExFau$t 1570 / 1168 / 426 Регистрация: 08.05.2012 Сообщений: 5,219
	13.09.2019, 16:05	2
	Попробуй этот https://rxmarbles.com/#race 0

@arvalon 22 / 7 / 2 Регистрация: 26.10.2012 Сообщений: 212 Записей в блоге: 1
	13.09.2019, 16:17 [ТС]	3
	Сообщение от ExFau$t Попробуй этот https://rxmarbles.com/#race Хм, не могу найти такой оператор в RXJava, кажется он есть только в RxJS? 0

@ExFau$t 1570 / 1168 / 426 Регистрация: 08.05.2012 Сообщений: 5,219
	13.09.2019, 16:26	4
	А, ну значит этот: http://reactivex.io/documentat... s/amb.html Не понял, что тут не подходит. 0

@arvalon 22 / 7 / 2 Регистрация: 26.10.2012 Сообщений: 212 Записей в блоге: 1
	13.09.2019, 16:34 [ТС]	5
	Сообщение от ExFau$t А, ну значит этот: http://reactivex.io/documentat... s/amb.html Не понял, что тут не подходит. C amb получается так что на этом операторе один раз на всё время подписки выбирается Observable, первым выпустивший событие. Второй игнорируется всё время. А нужно что бы последующий и ввод текста и клики по Go совместно работали и выпускалось событие прошедшее все фильтры первым. 0

@ExFau$t 1570 / 1168 / 426 Регистрация: 08.05.2012 Сообщений: 5,219
	13.09.2019, 16:49	6
	Ну случилось событие начала ввода, слушаем кнопку или ждём 2 секунды, дождались чего-то - выполнился поток и всё. Можно хоть 100 раз повторять, что не так? 0

@arvalon 22 / 7 / 2 Регистрация: 26.10.2012 Сообщений: 212 Записей в блоге: 1
	13.09.2019, 16:53 [ТС]	7
	Сообщение от ExFau$t слушаем кнопку или ждём 2 секунды Вот, вот в этой фразе похоже что вся загвоздка. Описать это в терминах rx-цепочек не удаётся. Если ввести текст и успеть нажать кнопку до истечения 2 секунд - два события приходят в подписчик. А хотелось бы одно, которое запустилось нажатием кнопки. 0