Rxjs субъект с несколькими наблюдателями с debounce подписывается только на последнего

У меня есть угловое приложение v7, где я использую тему Rxjs. Ниже приведен частичный код. Я использую подписку несколькими способами. Но работает только последняя подписка, а не остальные.

this.userSelectionChangeSubscription = this.userSelectionChangeSubject
    .pipe(debounceTime(environment.saveDebounceTime))
    .subscribe((saveCallback) => {
        this.reloadColumns();
        saveCallback();
    }); 

//on change of a dropdown 
onPremiumBasisChanged(premiumBasis: number[]): void {
    this.onUserSelectionChanged(() => this.saveMethodParameters());
}   

onDevelopmentMethodsChanged(developmentMethods: number[]): void {
    this.initialData.selectedDevelopmentMethods = developmentMethods;
    this.onUserSelectionChanged(() => this.saveMethodParameters());
}       

onUserSelectionChanged(saveCallback: () => void): void {
    this.userSelectionChangeSubject.next(saveCallback);
}   

private saveMethodParameters() {

// actual save code goes here

}

Какой правильный подход?

Спасибо

0 ответов

Другие вопросы по тегам