subject--analytics.directive.ts

private readonly onChanges$$ = new Subject();
private readonly onChanges$ = this.onChanges$$.pipe();

ngOnChanges({ events }: SimpleChanges) {
  this.onChanges$$.next();

  if (events) {
    this.registerEvents(this.events)
      .pipe(
        takeUntil(this.onChanges$),
        untilDestroyed(this)
      )
      .subscribe(event => this.logEvent(event, this.properties));
  }
}

ngOnDestroy() {
  this.onChanges$$.complete();
}