Полное отсутствие вызова в методе подписки Observable
Я работаю над угловым приложением и пытаюсь использовать RxObservable. Ниже приведен пример кода.
getMyData(){
console.info('get my account data called');
this.AccountService
.getMyAccountData()
.filter(_res => _res !== null)
.takeUntil(this.ngUnsubscribe)
.subscribe({
next: _response => {console.info('call finished');}
error: error => {
console.info('had an error');
handleHttpError(error);
},
complete: () => {
console.info('account data loaded is being set');
this.accountDataLoaded = true;
}
});
}
Теперь это приложение angular 2 (одностраничное приложение). Когда я перезагружаю страницу, вызывается полная часть вышеуказанной функции, и this.accountDataLoaded имеет значение true.
Однако, если я перейду к другому компоненту и вернусь к этому, полный не вызывается, и accountDataLoaded остается ложным.
Я вижу, что на консоли нет ошибки, так как я регистрирую ошибку, как вы можете видеть выше.
Я думаю, что это вызывает либо фильтр, либо функция takeUntil для этого наблюдаемого, но я не уверен.
Можете ли вы показать нам, как настроен ваш компонент и как в нем вызывается этот метод?
Я не уверен, почему complete не запускается без дополнительного контекста, но если это наблюдается из HTTP-вызова, HTTP-наблюдаемые всегда запускаются один раз, а затем завершаются, поэтому вам обычно не нужно использовать обратный вызов complete в дополнение к success .
Поскольку здесь вы не сохраняете эту подписку, ngUnsubscribe не находится в контексте. Данные учетной записи не должны быть нулевыми независимо от количества звонков. Поместите отладчик в вызов службы, чтобы проверить, правильно ли он попадает. Похоже, что какое-то другое условие не позволяет вызову даже произойти
Также вы можете закомментировать фильтр и вызовы takeUntill, чтобы увидеть, происходят ли ваши служебные вызовы в другом случае .. Просто чтобы точно определить, в чем может быть проблема
![Безумие обратных вызовов в javascript [JS]](https://i.imgur.com/WsjO6zJb.png)
Ответы 1
С RXjs поведение не вызывается, если вызывается ошибка. В вашем случае вам нужно сделать следующее.
getMyData(){
console.info('get my account data called');
this.AccountService
.getMyAccountData()
.filter(_res => _res !== null)
.takeUntil(this.ngUnsubscribe)
.subscribe({
next: _response => {console.info('call finished');}
error: error => {
console.info('had an error');
handleHttpError(error);
},
complete: () => {
console.info('account data loaded is being set');
this.accountDataLoaded = true;
}
}).add(() => {
//Called when operation is complete (both success and error)
});
}
покажите нам, где вы вызываете эту функцию, также покажите нам
ngUnsubscribe