可观察订阅仅接收第一个事件

Question

我有几个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"});
}

通过具有上述内容，问题是只有一个接收组件（我有多个接收组件）接收一个事件，并且不接收任何后续事件。

我做错了什么？这是什么在线样品？

谢谢！

Answer 1

您正确使用BehaviorSubject。它将重新发送新订阅的最后一个值。

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