Понимание потоков данных и нескольких подписчиков (с использованием модификации)

Question

Скажем, у меня есть 2 наблюдаемых объекта (A & B), которые по сути являются сетевыми вызовами (с использованием «Дооснащения» для предоставления контекста).

В настоящее время поток приложения выглядит следующим образом:

• & В имеют стартовал примерно в то же время (асинхронно).
• B выполняется 0 или более раз при взаимодействии пользователя

У меня есть 3 различных сценариев, которые я хочу слушать с учетом этих 2 Наблюдаемые/API вызовов.

1. Я хочу знать сразу, когда Наблюдаемые завершает
2. Я хочу знать сразу, когда Наблюдаемые B завершает
3. Я хочу знать, когда оба закончили

Во-первых, является ли это хороший вариант использования для RxJava?

Я знаю, как сделать каждый сценарий индивидуально (используя zip для последнего), хотя я не знаю, как делать все из них одновременно.

Если я подписываюсь на Наблюдаемый А, начинается А. Если я подписываюсь на B, начинается B. Если A & B полностью, прежде чем я подписаться на zip (a, b), я мог бы пропустить это событие и никогда не увидеть его полностью, не так ли?

Любое общее руководство будет оценено по достоинству. Мои знания RxJava довольно тонкие: P

Answer 1

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

Как вам нужно будет делиться состояниями между каждыми наблюдаемыми, вам придется преобразовать модифицированные холодные наблюдаемые в горячие наблюдаемые. (См here для получения дополнительной информации по этой теме)

ConnectableObservable a = service.callA().publish(); 
ConnectableObservable b = service.callB().publish(); 

a.subscribe((e) -> { /* onNext */ }, (ex) -> {/* onError */}, () -> {/* when A is completed */ }); 
b.subscribe((e) -> { /* onNext */ }, (ex) -> {/* onError */}, () -> {/* when B is completed */ }); 
a.mergeWith(b).subscribe((e) -> { /* onNext */ }, (ex) -> {/* onError */}, () -> {/* when A and B are completed */ }); 

a.connect(); // start subscription to a 
b.connect(); // start subscription to b 

Не делитесь объектом между OnCompleted методами или вы будете иметь дело с проблемами параллельно работающим.