46. Effects pattern: actions in, async work out

Что такое effect

Если scan превращает actions в state, то effect делает другое: actions → побочная работа (HTTP, таймер, сохранение) → новые actions. Это вторая половина паттерна Redux/NgRx Effects.

actions$.pipe(
  filter(a => a.type === 'save'),
  concatMap(a => api.save(a).pipe(map(() => ({ type: 'saved', id: a.id }))))
)

Почему concatMap для сохранений

Сохранения нельзя перемешивать. Если запустить два save через mergeMap, и второй закончится раньше, то старый ответ может перезаписать новое состояние на сервере. concatMap ставит их в очередь — это безопасно.

const { Subject, timer, filter, concatMap, map } = Rx;

const actions$ = new Subject();

const effect$ = actions$.pipe(
  filter(action => action.type === 'save'),
  concatMap(action => {
    return timer(20).pipe(
      map(() => ({ type: 'saved', id: action.id }))
    );
  })
);