Angular 2上的Ngrx Store,Effects,Http Ajax轮询设置

发布时间：2020-12-17 06:51:42 所属栏目：安全来源：网络整理

导读：我正在创建一个Ngrx Angular 2应用程序,并试图让我的http调用在一段时间后继续轮询.我已经看到使用了interval()函数,但是在Ngrx的情况下,当服务调用在@Effect()中完成时,它会给出错误.请指教： @Injectable()export class TasksEffects {constructor( privat

我正在创建一个Ngrx Angular 2应用程序,并试图让我的http调用在一段时间后继续轮询.我已经看到使用了interval()函数,但是在Ngrx的情况下,当服务调用在@Effect()中完成时,它会给出错误.请指教：

@Injectable()
export class TasksEffects {
constructor(
    private actions$: Actions,private TS: TaskService
){}

@Effect()
onLoadTasksLoadTasks$: Observable<Action> = this.actions$.ofType(tasksActions.ActionTypes.LOAD_TASKS)
    .switchMap(() => {
        return this.TS.index()
            .map((res) => new tasksActions.LoadTasksSuccessAction(res.json()))
            .catch(err => of(new tasksActions.LoadTasksFailAction(err)));
    });

我想每十秒运行一次switchMap功能.这不起作用.

@Effect()
onLoadTasksLoadTasks$: Observable<Action> = this.actions$.ofType(tasksActions.ActionTypes.LOAD_TASKS)
    .switchMap(() => {
        return this.TS.index()
            .map((res) => new tasksActions.LoadTasksSuccessAction(res.json()))
            .catch(err => of(new tasksActions.LoadTasksFailAction(err)));
    }).interval(10000);

类型错误是：

enter image description here

解决方法

如另一个答案所述,interval是一个静态函数,因此在Observable原型中不存在 – 这就是你的错误发生的原因.

相反,你应该能够使用timer实现你想要的.

import { Observable } from 'rxjs/Observable';
import 'rxjs/add/observable/of';
import 'rxjs/add/observable/timer';
import 'rxjs/add/operator/catch';
import 'rxjs/add/operator/map';
import 'rxjs/add/operator/switchMap';

@Effect()
onLoadTasksLoadTasks$: Observable<Action> = this.actions$
  .ofType(tasksActions.ActionTypes.LOAD_TASKS)
  .switchMap(() => Observable
    .timer(0,10000)
    .switchMap(() => this.TS.index()
      .map((res) => new tasksActions.LoadTasksSuccessAction(res.json()))
      .catch(err => Observable.of(new tasksActions.LoadTasksFailAction(err)))
    )
  );

使用计时器,可以指定初始延迟,并在此设置为零,以便计时器立即触发.之后,它将每十秒触发一次,但是如果收到另一个LOAD_TASKS动作,switchMap将看到它取消订阅并创建一个新的计时器等.

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!