Всем привет Почему то не получается сделать повторение запроса при ошибке В

компоненте делаю так:
this.cityByCodeService
.getCities()
.pipe(
retryWhen((errors) => {
return errors.pipe(delay(2000), take(5));
}),
)
.subscribe((cityMapping) => {
this.city = cityMapping[this.columnValue];
});

А в сервисе делаю так:
getCities(): Observable<CityMapping> {
if (this.loading) {
return throwError('LOADING');
}

if (this._cities$) return this._cities$;

this.loading = true;

this._cities$ = this.citiesService.getCities().pipe(
map((cities) => {
return cities.reduce((acc, value) => {
return { ...acc, [value.ubp_city_id]: value.name };
}, {} as CityMapping);
}),
take(1),
finalize(() => (this.loading = false)),
);

return this._cities$;
}

Подскажите в чем проблема?

для начала попробуйте throwError(new Error("'LOADING'"))

кстати, советую обернуть данные в такой generic, тут пример , так удобней работать https://github.com/evoytenkoapps/angular-best-practices/blob/c686d760fef426080ad9ab91d60dfe3ecfc55f67/examples/src/app/data-facade/_services/api/animal-http-production.service.ts#L19

Не помогло, сам повтор как будто не срабатывает

Да я пока в черновую пишу, потом отрефакторю красиво, но спасибо)

поставьте дебаг. возвращается ли вообще return throwError('LOADING');

прологируейте эррор this.cityByCodeService .getCities() .pipe( catchError(err= > { console.error(err); return throwError(err)}) retryWhen((errors) => { return errors.pipe(delay(2000), take(5)); }), )

да ошибки приходят

но он как будто не ждет 2сек а сразу пытается вызватьеще раз

попробуйте так return of().pipe(delay(2000), switchmap(() => errr), take(5));

Да вот именно что такой код как у меня всегда работал, только там был ориентир на ошибку с http запроса, а тут я как бы сам ее инициализирую

и? в итоге то так работает?