Привет! как заставить один стрим подождать с выполнением, пока не

закончится другой?

зачем мне это? Пытаюсь сделать в интерсепторе такую логику: смотрит в локал стораж - не истек ли срок действия токена -> если истек посылает на бек запрос с рефрешем, в котором будет новый токен.

так вот всем запросам остальным, хочется сказать, чтобы подождали нового токена, а то отправляются со старым

спасибо.


P.S. Запрос рефреша в интерсепторе выглядит так

if (isTokenExpired && !this.auth.isRefreshing) {
return this.auth.refreshToken()
.pipe(
switchMap(token => {
req = req.clone({
headers: req.headers.append('Authorization', 'Bearer ' + token.access)
})
return next.handle(req)
.pipe(catchError(this.catchErrors.bind(this)))
}))
}

в интерсепторе такое ловим: catchError(error => { if (error.status !== 401) { return throwError(error); } if (this.refreshTokenInProgress) { return this.refreshTokenSubject.pipe( filter(result => result !== null), take(1), switchMap(() => next.handle(this.addAuthenticationToken(req))) ); } else { this.refreshTokenInProgress = true; this.refreshTokenSubject.next(null); return this.authService.refreshToken().pipe( switchMap(token => { this.refreshTokenInProgress = false; this.refreshTokenSubject.next(token); return next.handle(this.addAuthenticationToken(req)); }), catchError(err => { this.refreshTokenInProgress = false; this.authService.logout().subscribe(); return throwError(err); }) ); } }) и каждый запрос ждёт один рефреш + делаем превентивный рефреш уууу рефакторить это впадлу

Спасибо, сейчас буду впаивать

У меня почему - то в этом месте никак не идет запрос. Консоль пустая и все останавливается return this.auth.refreshToken().pipe( switchMap(token => { this.refreshTokenInProgress = false; this.refreshToken$.next(token.access) console.log('REFRESHING REQUEST', req.url) return next.handle(this.addAuthenticationToken(req)) }), catchError(err => { this.refreshTokenInProgress = false this.auth.logout() return throwError(err) }) ) нет идей?

Потому что рефреш снова запускает интерсептор и получается рекурсия :)

вангуешь