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

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

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

Доброго для.
Есть задача. Имеем 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 секунд - два события приходят в подписчик. А хотелось бы одно, которое запустилось нажатием кнопки.

Новые блоги и статьи Все статьи Все блоги /
Загрузка PNG-файла с альфа-каналом с помощью библиотеки SDL3_image на Android 8Observer8 27.01.2026 Содержание блога SDL3_image - это библиотека для загрузки и работы с изображениями. Эта пошаговая инструкция покажет, как загрузить и вывести на экран смартфона картинку с альфа-каналом, то есть с. . .	влияние грибов на сукцессию anaschu 26.01.2026 Бифуркационные изменения массы гриба происходят тогда, когда мы уменьшаем массу компоста в 10 раз, а скорость прироста биомассы уменьшаем в три раза. Скорость прироста биомассы может уменьшаться за. . .	Воспроизведение звукового файла с помощью SDL3_mixer при касании экрана Android 8Observer8 26.01.2026 Содержание блога SDL3_mixer - это библиотека я для воспроизведения аудио. В отличие от инструкции по добавлению текста код по проигрыванию звука уже содержится в шаблоне примера. Нужно только. . .	Установка Android SDK, NDK, JDK, CMake и т.д. 8Observer8 25.01.2026 Содержание блога Перейдите по ссылке: https:/ / developer. android. com/ studio и в самом низу страницы кликните по архиву "commandlinetools-win-xxxxxx_latest. zip" Извлеките архив и вы увидите. . .
Вывод текста со шрифтом TTF на Android с помощью библиотеки SDL3_ttf 8Observer8 25.01.2026 Содержание блога Если у вас не установлены Android SDK, NDK, JDK, и т. д. то сделайте это по следующей инструкции: Установка Android SDK, NDK, JDK, CMake и т. д. Сборка примера Скачайте. . .	Использование SDL3-callbacks вместо функции main() на Android, Desktop и WebAssembly 8Observer8 24.01.2026 Содержание блога Если вы откроете примеры для начинающих на официальном репозитории SDL3 в папке: examples, то вы увидите, что все примеры используют следующие четыре обязательные функции, а. . .	моя боль iceja 24.01.2026 Выложила интерполяцию кубическими сплайнами www. iceja. net REST сервисы временно не работают, только через Web. Написала за 56 рабочих часов этот сайт с нуля. При помощи perplexity. ai PRO , при. . .	Модель сукцессии микоризы anaschu 24.01.2026 Решили писать научную статью с неким РОманом

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

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

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