Angular: как синхронизировать двух наблюдателей в **разных местах** кода

Используйте силу наблюдений. switchMap гарантирует, что первый наблюдаемый объект завершится первым

constructor(
    private dataService: DataService,
    settingsService: SettingsService
) {}

onInit() {
    this.loadData();
}

loadData() {
    this.settingsService.get().pipe(
        switchMap(settings => this.dataService.get(settings))
    ).subscribe(data => {
        // do something
    })
}

вы можете использовать repeatWhen:

    private reload$ = new Subject<void>();
    
    constructor(
        private dataService: DataService,
        settingsService: SettingsService
    ) {}
 
    onInit() {
        settingsService.get()
            .pipe(
                switchMap(settings => this.dataService.get(settings).pipe(repeatWhen(() => reload$))),
                
            ).subscribe({next: (data) => this.data = data});
    }

    reloadData() {
        this.reload$.next();
    }

Думаю, здесь вам нужна Тема. См. код и пояснения ниже.

  //will be use to trigger if settings api completes
  private settingsReady: Subject<any> = new Subject<any>();
  
  //make settingsReady as observable so we can subscribe to it
  private settingsReady$: any = this.settingsReady.asObservable();
  
  //mock the settings api that will be executed after 5 sec
  private settingsApi$ = of('settingsApi').pipe(
    delay(5000),
  );
  
  //mock the data api that will be executed after 2 sec
  private dataApi$ = of('dataApi').pipe(
    delay(2000),
  );
  
  constructor() { 
    //trigger the settings api
    this.settingsApi$.subscribe((result: any) => {
      console.log('settingsApi execute after 5 seconds =>', result);
  
      //inform settingsReady subject that setting api already complete
      //##KEY_PART you can also pass the result of the api here
      this.settingsReady.next(result);
    });
  }
  
  ngOnInit() {
    //will only trigger once settings api complete
    //that is when settingsReady call next on ##KEY_PART
    this.settingsReady$.subscribe((settingsResult) => {
      console.log('settings result from Subject =>', settingsResult);
      this.loadData();
    });
  }
  
  loadData() {
    //trigger the data api
    this.dataApi$.subscribe((result) => {
      console.log('dataApi execute after settingsApi completes =>', result);
    });
  }

Результат приведенного выше кода:

> settingsApi execute after 5 seconds => settingsApi
> settings result from Subject => settingsApi
> dataApi execute after settingsApi completes => dataApi

Примечание. В некоторых случаях вам может потребоваться немедленно запустить loadData, не дожидаясь первоначального возврата API настроек. Для такого сценария вы можете изучить BehaviorSubject.

Вы можете просто использовать switchMap, чтобы сначала загрузить данные из настроек, а затем вызвать dataService.get() с результатом:

readonly data$ = this.settingsService.get().pipe(
  switchMap(settings => this.dataService.get(settings))
);

constructor(private dataService: DataService, private settingsService: SettingsService) {}

Обратите внимание, что я не буду использовать хук жизненного цикла ngOnInit(), а просто создам поток, который будет потребляться с помощью асинхронного канала в шаблоне. Это делает код намного меньше, и вам не нужно отписываться от подписок в хуке ngOnDestroy().

• Если вам нужен только один результат, и любой из методов остается открытым, вы можете легко добавить take(1) после switchMap.
• Если существует несколько привязок к data$ в шаблоне then, рассмотрите возможность добавления оператора shareReplay в конец потока, чтобы не выполнять несколько базовых вызовов.