Мне нужно отфильтровать поток наблюдаемых значений на основе некоторого условия, которое смоделировано как наблюдаемое внутри моего значения.
class ValueObject {
BehaviorSubject<Boolean> condition = ...;
}
...
valueObjects.filter(valueObject -> condition).subscribe(valueObject -> ...);
Моя цель состоит в том, чтобызапускать поток, если a) было выдвинуто новое значение или b) изменилось условие для фильтра.
(Бонус: проделайте то же самое со списками ValueObjects (Observable<List<ValueObject>>) и с этим уродливым Object[] - combineLatest ...)
Есть ли какая-то лучшая практика дляэта проблема?Спасибо.