RxJava/Android отслеживает прогресс нескольких подписчиков, запущенных в разное время

Я бы использовал отдельные BehaviorSubject и scan для отслеживания статуса выполнения. Это очень похоже на переменную экземпляра, но, возможно, это может вдохновить вас на лучшее решение. Что-то вроде этого:

private final BehaviorSubject<Integer> mProgressSubject = BehaviorSubject.create(0);

public  Observable<String> firstLongRunningOperations() {
    return Observable.just("First")
            .doOnSubscribe(() -> mProgressSubject.onNext(1))
            .finallyDo(() -> mProgressSubject.onNext(-1)));
}

public  Observable<String> secondLongRunningOperations() {
    return Observable.just("Second")
            .doOnSubscribe(() -> mProgressSubject.onNext(1))
            .finallyDo(() -> mProgressSubject.onNext(-1));
}

public Observable<Boolean> isOperationInProgress() {
    return mProgressSubject.asObservable()
            .scan((sum, item) -> sum + item)
            .map(sum -> sum > 0);
}

Использование будет таким:

isOperationInProgress()
        .subscribe(inProgress -> {
            if (inProgress) {
                //disable controls
            } else {
                //enable controls
            }
        });

При таком подходе у вас может быть любое количество длительных операций, и вам не нужно запускать их все. Только не забудьте позвонить doOnSubscribe и finallyDo.

PS. Извините, не проверял, но должно работать.

Чтобы сделать это возможным, пусть обе длительные операции генерируют событие onNext для PublishSubject. Объедините обе темы с помощью функции zip или CombineLatest и подпишитесь на это. Как только функция объединения получает событие, это означает, что оба субъекта сгенерировали событие onNext, поэтому обе длительные операции завершены, и вы можете включить 3-ю кнопку.

private PublishSubject<Boolean> firstSubject = PublishSubject.create();
private PublishSubject<Boolean> secondSubject = PublishSubject.create();

@Override
public void onStart() {
    super.onStart();
    subscribeToResult();
}

private Observable<Integer> firstOperation() { 
    return Observable.just(100)
                .delay(1000) // takes a while
                .subscribe(tick -> firstSubject.onNext(true));
}

private Observable<Integer> firstOperation() { 
    return Observable.just(200)
                .delay(1000) // takes a while
                .subscribe(tick -> secondSubject.onNext(true));
}

private void subscribeToResult() {
    Observable.zip(
        firstSubject,
        secondSubject,
        (firstResult, secondResult) -> return true
    ).subscribe(
        tick -> thirdButton.setEnabled(true)
    )
}

Обязательно взгляните на функции комбайна RxJava.