BehaviorSubject发送旧数据问题：Angular组件订阅重复获取值

你的问题源于BehaviorSubject的特性：它会在订阅时立即向观察者发送当前存储的最新值（包括你设置的初始值null）。要只获取createSession()推送的新值，可采用以下几种方案：

方法1：用skip(1)跳过初始值 #

通过RxJS的skip操作符，跳过第一次发出的初始null值，仅接收后续推送的新值：

export class CreateSessionComponent {
  constructor(private sessionService: SessionService) {}

  public createUserAndSession(): void {
    this.sessionService.createSession();

    this.sessionService.session$.pipe(skip(1)).subscribe({
      next: (data) => console.log(data), // 仅输出'something'
    });
  }
}

方法2：过滤掉初始的null值 #

用filter操作符筛选非null结果，适合你明确初始值为null、只关心非空值的场景：

export class CreateSessionComponent {
  constructor(private sessionService: SessionService) {}

  public createUserAndSession(): void {
    this.sessionService.createSession();

    this.sessionService.session$.pipe(filter(data => data !== null)).subscribe({
      next: (data) => console.log(data), // 仅输出'something'
    });
  }
}

方法3：改用Subject（注意订阅时机） #

如果不需要保留初始值，可将BehaviorSubject替换为普通Subject——它不会在订阅时发送初始值，仅推送订阅后的新值。但必须先订阅再调用createSession()，否则会错过推送的值：

修改服务代码：

export class SessionService {
  private sessionSubject = new Subject<any | null>();
  public session$ = this.sessionSubject.asObservable();

  public createSession(): void {
    this.sessionSubject.next('something');
  }
}

修改组件代码：

export class CreateSessionComponent {
  constructor(private sessionService: SessionService) {}

  public createUserAndSession(): void {
    // 先订阅
    this.sessionService.session$.subscribe({
      next: (data) => console.log(data), // 仅输出'something'
    });

    // 再调用createSession
    this.sessionService.createSession();
  }
}

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