Как найти два элемента, которые удовлетворяют определенным условиям, создать элемент и продолжить поиск в RxJava?

Question

У меня есть Flowable (холодный), к которому мне нужно применить следующий оператор:

1. Пройдите по элементам потока по порядку, пока не будет выполнено условие A. Кэшируйте элемент, соответствующий этому условию.
2. Перейдите к следующему элементу, но теперь проверьте условие B. Если найден элемент, соответствующий этому условию
3. Применение функции, которая принимает оба ранее собранных элемента и создает новый элемент во втором потоке.
4. Продолжайте до тех пор, пока не останется элементов, которые вначале удовлетворяют условию A, и элемента, который соответствует условию B. Удалите все кэшированные элементы.

Обратите внимание, что после излучения следующий элемент, который проверяется на A, должен быть таким же, который только что выполнил условие B, поскольку элемент может удовлетворять обоим условиям.

Я не могу придумать, как это сделать с помощью RxJava. Моими первыми инстинктами были takeUntil () и / или skipUntil (), но оба применяются только один раз. И у меня пока недостаточно опыта реактивного программирования, чтобы написать собственный оператор.

Любые мысли и указания приветствуются!

Answer 1

Отфильтруйте A и B, соберите их в список, затем проверьте список для последующих A и B, примените функцию, добавьте результат в список и верните этот список в flatMapIterable:

source
.filter(v -> isA(v) || isB(v))
.toList()
.flatMapIterable(list -> {
     List<C> result = new ArrayList<C>();

     for (int i = 0; i < list.size() - 1; i++) {
         T a = list.get(i);
         T b = list.get(i + 1);
         if (isA(a) && isB(b)) {
             result.add(functionAB(a, b));
             i++;
         }
     }

     return result;
})