NgRx取消订阅存储效果

import { Component, OnInit, OnDestroy } from '@angular/core';
import { Store } from '@ngrx/store';
import { Subject } from 'rxjs';
import { takeUntil } from 'rxjs/operators';
import { MyEffectService } from './my-effect.service';

@Component({
  selector: 'app-my-component',
  templateUrl: './my-component.component.html',
  styleUrls: ['./my.component.css']
})
export class MyComponent implements OnInit, OnDestroy {
  private destroy$ = new Subject<void>();

  constructor(private store: Store, private myEffectService: MyEffectService) {}

  ngOnInit() {
    this.myEffectService.myEffect$.pipe(takeUntil(this.destroy$)).subscribe();
  }

  ngOnDestroy() {
    this.destroy$.next();
    this.destroy$.complete();
  }
}

import { Injectable } from '@angular/core';
import { Actions, createEffect, ofType } from '@ngrx/effects';
import { of } from 'rxjs';
import { catchError, map, mergeMap, take } from 'rxjs/operators';
import { MyService } from './my.service';
import { myAction, myActionSuccess, myActionFailure } from './my.actions';

@Injectable()
export class MyEffects {
  myEffect$ = createEffect(() =>
    this.actions$.pipe(
      ofType(myAction),
      mergeMap(() =>
        this.myService.doSomething().pipe(
          take(1), // 只取一次
          map(result => myActionSuccess({ result })),
          catchError(error => of(myActionFailure({ error })))
        )
      )
    )
  );

  constructor(
    private actions$: Actions,
    private myService: MyService
  ) {}
}