Я пытаюсь преобразовать следующий эффект @ngrx в эпопею, наблюдаемую при редукции:
@Effect()
startReading$ =
this.actions$.ofType('START_READING').switchMap(() => {
return Observable.interval(200)
.takeUntil(
this.actions$.ofType('ABORT_PAGE_PROCESSING))
.mapTo({ type: 'PROCESS_PAGE' });
});
Моя попытка заключалась в следующем:
export const startReadingEpic = action$ =>
action$
.ofType('START_READING')
.switchMap(() =>
Observable.interval(200)
.takeUntil(action$.ofType('ABORT_PAGE_PROCESSING'))
.mapTo({ type: 'PROCESS_PAGE' })
);
который, похоже, не работает. Однако возврат одного Observable.of ({type: 'PROCESS_PAGE'}) работает нормально.
Пропустил ли я что-нибудь, что требовалось для redux-observable, которое изначально обрабатывается @ngrx?
Спасибо.
