订阅 Observable 并获取特定类型的事件

Question

我有以下 Angular 服务：

export class EventService {

  private subject = new Subject<Event>();

  send(code: EventCode, data?: any) {
    this.subject.next(event);
  }

  clear() {
    this.subject.next();
  }

  get(): Observable<Event> {
    return this.subject.asObservable();
  }

}

Event 和 EventCode 在哪里：

export class Event {
  code: EventCode;
  data: any;
  constructor(code: EventCode, data?: any) {
    this.code = code;
    this.data = data;
  } 
} 

export enum EventCode {
  Created,
  Deleted,
  Updated
}

那我使用如下：

this.eventService.get().subscribe((event: Event) => { 
  // Do something 
});

我希望能够仅订阅具有特定 EventCode 的事件。

或者可能只对带有特定EventCode 的事件做出反应......

这可能吗？我该怎么做？

Answer 1

在我们开始之前，这是：

this.eventService.get().subscribe((event: Event) => { 
  // Do something 
});

当组件销毁时会泄漏内存，因为您没有取消订阅。改为这样做。

export class MyComponent implements OnInit, OnDestroy {
  // store subscrition
  private eventServiceSubscription: Subscription;

  ngOnInit() {
        this.eventServiceSubscription = this.eventService.get().subscribe((event: Event) => {
          // check event code
          if(event.code === 'someEventCode') {
            // process event
           }
         });
   }

   ngOnDestroy() {
     this.eventServiceSubscription.unsubscribe();
   }
}