在Angular 2中设置Ngrx Store、Effects、Http Ajax轮询

Question

我正在创建一个 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)));
    });

我希望每10秒运行一次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);

类型错误是：

- notANerdDev

Answer 1

如其他答案所述，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)))
    )
  );

使用 timer，可以指定初始延迟时间，这里设置为零，以便立即触发计时器。之后，它将每隔十秒钟触发一次，但如果接收到另一个 LOAD_TASKS 动作，则 switchMap 将看到它被取消订阅并创建一个新的 timer。

- cartant

---

什么会停止或取消Observable.timer？即使接收到所需的数据，它不会永远继续下去吗？ - adam-beck

没有什么能阻止它。OP想要轮询。 - cartant

我该如何使用操作负载和rxjs 6来完成这个任务？https://dev59.com/c67la4cB1Zd3GeqPako0?noredirect=1#comment91477694_52263977 - FussinHussin

Answer 2

在rxjs 5中，interval()是一个静态函数。你只能将它用作创建者Observable.interval(1)。

试试这个。

this.actions$.ofType(tasksActions.ActionTypes.LOAD_TASKS)
  .skipUntil(Observable.interval(10000))
  .switchMap(res => {...})

- Sasxa