首页 > 解决方案 > 可观察订阅只接收第一个事件

问题描述

我有一些 Angular 组件,我使用 BehaviorSubject 在它们之间传递事件。

服务:

@Injectable()
export class SiteManagementEventService {
  private messageSource = new BehaviorSubject<SiteManagementEvent>(defaultEvent);   
  data = this.messageSource.asObservable();

  constructor() {}

  // publish the event using the service
  public publish(event: SiteManagementEvent) {
    if (event !== null) {
      this.messageSource.next(event);
    }
  }
}

发布事件:

constructor (
  .......
  private eventService: SiteManagementService,
) {}
........
this.eventService.publish(event);

订阅事件:

constructor (
  .......
  private eventService: SiteManagementService,
) {}

onInit() {
  ......
  this.eventService.data.subscribe(event => {console.log("event received"});
}

有了上述,问题是只有一个接收组件(我有多个接收组件)接收一个事件,并且没有接收任何后续事件。

我做错什么了吗?有这方面的在线样本吗?

谢谢!

标签: angularrxjs6behaviorsubject

解决方案


您正在正确使用 BehaviorSubject。它会将最后发出的值重播给新订阅。

通过使用确保您的服务是单例的@Injectable({provideIn: "root"})


推荐阅读