Как можно организовать код в стиле RxJS, если нужно по условию повторять запрос до тех пор, пока определённое условие не будет выполнено? Какой оператор нужно, я понимаю (takeUntil), а вот как сделать так, чтобы, если условие не выполнено, запрос выполнялся заново в этом же потоке?
Нужно subject использовать и типа, как-то
subject.next или как-то по другому нужно организовать?
Соль в том, что следующий запрос не должен выполняться, пока не закончен предыдущий (и если условие удовлетворено).