Кажется, что эти две функции очень похожи. У них одинаковая подпись (принимает rx.functions.Func1<? super T, ? extends Observable<? extends R>> func ), и их мраморные диаграммы выглядят точно так же. Не могу вставить сюда картинки, но...

У меня есть две наблюдаемые, и я использовал concatDelayError для последовательной обработки. Моя проблема в том, что onNext и onCompleted вызываются заблаговременно до обработки. Как я узнаю, что вся обработка завершена с помощью...

У меня есть приложение, написанное на машинописном языке с использованием rxjs, где я использую flatMap для возврата списка из 5000 наблюдаемых, но я не хочу, чтобы все они были подписаны одновременно. Я пытался использовать concatMap, но это очень...

Я использую concatMap для обработки потока элементов по одному с длительной операцией. В какой-то момент мне нужно «прервать» эту длительную операцию, но только для текущего элемента: @Test public void main() throws InterruptedException {...