constructor(service: ...) {
const storedUser = new BehaviorSubject<null | User>(null);
this.currentUser = storedUser.pipe(
switchMap(stored => stored
? of(stored)
: service.get(...).pipe(
switchMap(remote => {
storedUser.next(remote);
return NEVER;
})
)
),
publishReplay(1), refCount(),
);
}
getCurrentUser(): Observable<User> {
return this.currentUser;
}
}
Спасибо 🙏 , попробую
есть вопрос по поводу данного кода. почему в switchMap после get-a делается storedUser.next(remote) и return NEVER а не просто return of(remote), то есть вообще можно было пайп к get() не написать. работает аналогично, в чем суть ?
Обсуждают сегодня