туториале видел вот такой метод для логина
login(credentials): Observable<any> {
return this.http.post(environment.baseUrl+'/apiv2/auth/login', {credentials}).pipe(
tap((data: any) => {
this.authUser$.next(data.user);
this.isAuthenticated$.next(true);
console.log('login this.authUser$ :', this.authUser$.getValue());
}),
switchMap((data: any) => from(Storage.set({key: TOKEN_KEY, value: data.token}))
//switchMap((data: any) => from(Storage.set({key: AUTH_USER_DATA, value: JSON.stringify(data.user)})))
);
}
Я так понимаю, что Storage.set это хрень долговыполняющаяся и поэтому асинхронная, и чтобы сохранить токен в локалстораже, стрим с результатом этой операции при помощи switchMap микшируют со стримом http-запроса и ресолвится всё это когда оба стрима отрапортуют что всё ок.
Но как быть, если помимо токена мне надо сохранить ещё что-то, данные юзера, например ? Просто добавить новый switchMap я не могу, потому что он, похоже, возвращает мне не data, а уже что-то другое своё.
Как вообще принято поступать в rxjs для подобных ситуаций, когда есть N стримов, которые надо все дождаться ?
Ну вон в tap же происходит то, что Вы описали, а именно - сохранение данных пользователя
если нужно дождаться то это вроде делают forkjoin и zip почитайте их
Спасибо, посмотрю.
в принципе вы правы, в rx нет такого оператора, который выполняет новый запрос и сохраняет результаты предыдущего. Если собрать из доступных это будет примерно так switchMap(value1 => forkJoin([of(value1), request(...)])), ).subscribe(([value1, value2]) => ... Если такое нужно часто, то можно сделать свою обертку и использовать ее
Возможн гляньте как вариант в сторону expand, он немного работает непонятно, но позволяет аккумулировать значение предыдущих запросов
Спасибо, я решил ту проблему при помощи forkJoin.
Обсуждают сегодня