Зависимые вложенные наблюдаемые

Я сделал некоторые предположения относительно вашего кода до написания решения. Если предположения неверны, то и ответ может быть таким же.

1. executingSomething() – это синхронный метод с несвязанной функциональностью, за исключением того, что вы хотите, чтобы все это завершилось ошибкой, если возникнет исключение.
2. anotherSubscription это не Subscribtion, а Observable (это разные вещи).

Вот как я решил бы вашу проблему:

class SomeClass {
  private method1(): Observable<any> {
    try {
      executingSomething();
    } catch (err) {
      // This would return an errorred observable, which is great, since
      // you can still subscribe to it (no need to change the return type
      // of this method).
      return throwError(err);
    }

    return this.anotherSubscription.pipe(
      tap(() => {
        console.log('Controls is reaching here!');
      }),
    );
  }

  private method2(): Observable<any> {
    // This can be whatever obervable, using of(null) for demo purposes.
    return of(null);
  }

  private parentMethod() {
    this.method1()
      .pipe(
        switchMap(valueFromAnotherSubscription => {
          // UPD1 - Implement your custom check here. This check will determine
          // whether `method2` will be called.
          if (valueFromAnotherSubscription === targetValue) {
            return this.method2();
          } else {
            // UPD1 - If the check evaluates to `false`, reemit the same value
            // using the `of` operator.
            return of(valueFromAnotherSubscription);
          }
        }),
      )
      .subscribe(() => {
        console.log('Done!');
      });
  }
}

Ключевым оператором здесь, как правильно указал Кевин, является switchMap. Каждый раз, когда наблюдаемое (anotherSubscription) испускается, switchMap отменяет его и подписывается на другое наблюдаемое (независимо от того, что возвращается из method2).

Это происходит последовательно, поэтому method2 будет подписан на после method1 испускания. Если method1 сработает, весь конвейер выйдет из строя. Вы также можете filter просмотреть результаты method1, чтобы решить, хотите ли вы перейти на method2.

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

Обновление 1

См. код, обозначенный комментариями UPD1.

Имейте в виду, что если anotherSubscription выдает ошибку, функция switchMap все равно вызываться не будет.

Вы можете явно вернуть значение serviceN в serviceN+1. Вот идея:

private setupStuff() {
  this.initRouteParams()
    .pipe(
      switchMap(serviceId => {
        return zip(of(serviceId), this.getFileInfo(serviceId))
      }),
      switchMap(([serviceId, filename]) => {
        return zip(of(serviceId), of(filename), this.getExistingFile(serviceId, filename))
      })
    )
    .subscribe(([serviceId, filename, response]) => {
      console.log(serviceId, filename, response);
    })
}

Я не хочу, чтобы метод 2 выполнялся до тех пор, пока ответ от метода 1 не будет положительным.

Если вы просто хотите, чтобы излучение obs2 запускалось после излучения obs1 (независимо от того, что излучает obs1), просто используйте switchMap:

fromEvent(document, 'click')
  .pipe(
    switchMap(() => of([1]))
  )
  .subscribe(console.log); <--- will emit [1] only after the user clicks.

Если вам нужно, чтобы obs2 выдавал только после того, как obs1 выдает определенное значение, используйте switchMap с оператором фильтра (https://www.learnrxjs.io/learn-rxjs/operators/filtering/filter):

const obs$ = of(true); 
const obs2$ = of([1,2,3]);

    obs$.pipe(
        filter((result) => result === true),
        switchMap(() => obs2$)
      ).subscribe(console.log) <--- returns [1,2,3] since filter condition returns true

если вам нужно что-то вроде оператора If Else, используйте условный оператор IIF (https://www.learnrxjs.io/learn-rxjs/operators/conditional/iif):

const even$ = of('even');
const odd$ = of('odd');

interval(1000).pipe(
  mergeMap(v =>
    iif(
      () => v % 2 === 0,
      even$,
      odd$
    ))
).subscribe(console.log); <--- will emit every second a string "even" or "odd" based on the condition.