在effect()中使用防抖技术

在Angular中，effect()函数是处理Redux Action的主要函数。有时候在处理这些Action时，我们需要防抖的功能，以避免在短时间内反复执行相同的逻辑。

解决方法是使用rxjs的防抖操作符“debounceTime()”。首先导入rxjs库并实现debounceTime()操作符，然后在effect()函数中使用它即可实现防抖效果。

示例代码如下：

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

@Injectable()
export class MyEffect {

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

  myAction$ = createEffect(() => this.actions$.pipe(
    ofType('[MyComponent] My Action'),
    debounceTime(500), // 防抖
    mergeMap(() => this.myService.getData().pipe(
      map(data => ({ type: '[MyEffect] My Action Success', payload: data })),
      catchError(() => of({ type: '[MyEffect] My Action Error' }))
    ))
  ));

}