Angular Observable无法接收值：用户数据更新时订阅未触发

问题根源 #

你用of(this.currentUser)创建的Observable是冷Observable，它只会在订阅时发射一次初始的currentUser对象。后续即使修改currentUser的值，这个Observable也不会发射新值——因为of不具备监听对象变化的能力，且仅发射一次数据。

解决方案：改用BehaviorSubject #

将普通变量和of替换为BehaviorSubject，它能保存当前最新值，且在数据更新时主动发射新值通知订阅者。

修改后的UserService代码 #

import { BehaviorSubject, Observable } from 'rxjs';
import { userDto } from './your-path-to-userDto'; // 替换为实际路径

@Injectable({ providedIn: 'root' })
export class UserService {
  // 用BehaviorSubject保存当前用户数据，初始值为空对象
  private currentUserSubject: BehaviorSubject<userDto> = new BehaviorSubject<userDto>({});
  // 对外暴露只读的Observable，避免外部直接修改Subject
  public currentUserObserv: Observable<userDto> = this.currentUserSubject.asObservable();

  // 提供更新用户数据的方法，从Auth0获取到新数据时调用此方法
  updateCurrentUser(user: userDto): void {
    this.currentUserSubject.next(user);
  }
}

在Auth0订阅中更新用户数据 #

当从Auth0获取到用户数据时，调用updateCurrentUser方法发射新值：

// 示例：Auth0用户数据订阅回调
this.auth0Service.user$.subscribe(authUser => {
  // 将Auth0返回的用户数据转换为你的userDto格式
  const newUser: userDto = {
    id: authUser.sub,
    name: authUser.name,
    // 其他字段映射逻辑
  };
  this.userService.updateCurrentUser(newUser);
});

路由服务无需修改 #

你的routingService.ts中的订阅逻辑保持不变，当currentUserObserv发射新值时，会自动触发handleRoles方法：

private userSubscription = this.userService.currentUserObserv.subscribe(
  user => this.handleRoles(user)
);

为什么用BehaviorSubject？ #

• 它是Subject的子类，既可以作为Observable被订阅，又能通过next()主动发射新值。
• 会保存当前最新值，新订阅的观察者能立即拿到最新数据，符合用户数据的状态管理需求。

内容的提问来源于stack exchange，提问作者Vicklo