даю приложение 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);

Ошибка типа: