停止监听NGRX中的操作

import { Effect, Actions, ofType } from '@ngrx/effects';
import { Observable, Subject } from 'rxjs';
import { takeUntil } from 'rxjs/operators';

@Injectable()
export class MyEffects {
  private unsubscribe$ = new Subject<void>();

  constructor(private actions$: Actions) {}

  @Effect()
  myEffect$: Observable<any> = this.actions$.pipe(
    ofType(MyActionTypes.SOME_ACTION),
    takeUntil(this.unsubscribe$),
    // Perform desired side effects here
  );

  // Call this method to stop listening
  stopListening() {
    this.unsubscribe$.next();
    this.unsubscribe$.complete();
  }
}

export class MyComponent implements OnDestroy {
  constructor(private myEffects: MyEffects) {}

  ngOnDestroy() {
    this.myEffects.stopListening();
  }
}