取消ngrx效果中的计时器

import { Effect, ofType, Actions } from '@ngrx/effects';
import { Injectable } from '@angular/core';
import { Observable, of } from 'rxjs';
import { map, switchMap, catchError } from 'rxjs/operators';

@Injectable()
export class MyEffect {
  private timer: any; // 计时器变量

  constructor(private actions$: Actions) {}

  @Effect()
  myEffect$: Observable<any> = this.actions$.pipe(
    ofType('START_EFFECT'), // 开始阶段的action类型
    switchMap(action => {
      // 创建计时器
      this.timer = setTimeout(() => {
        // 执行某些操作
      }, 1000);

      return of({ type: 'EFFECT_SUCCESS' }); // 返回成功的action
    }),
    catchError(error => {
      // 处理错误
      return of({ type: 'EFFECT_ERROR', payload: error });
    })
  );

  @Effect()
  stopEffect$: Observable<any> = this.actions$.pipe(
    ofType('STOP_EFFECT'), // 结束阶段的action类型
    map(action => {
      // 取消计时器
      clearTimeout(this.timer);

      return { type: 'EFFECT_STOPPED' }; // 返回停止的action
    })
  );
}