Observable.merge ведет себя иначе в эпосе
В приложении React / Redux я использую Redux Observable и хочу, чтобы эпик выводил два разных действия.
Сначала я попробовал это:
const epic1 = action$ =>
action$
.ofType("A")
.mapTo({ type: "B" })
.merge(Observable.of({ type: "C" }));
Так как это не сработало, пришлось переключиться на:
const epic2 = action$ =>
action$
.ofType("D")
.mergeMap(value =>
Observable.merge(
Observable.of({ type: "E" }),
Observable.of({ type: "F" })
)
);
См. Этот CodeSandbox пример.
Дело в том, что я не уверен, что понимаю, почему первая попытка не сработала, потому что в приведенном ниже примере она хорошо работает вне эпоса:
var observable = Observable.of({type: "A"})
.mapTo({type: "B"})
.merge(Observable.of({ type: "C" }));
observable.subscribe(value => {
this.setState(prevState => ({
values: [...prevState.values, value]
}));
});
Есть идеи, почему в эпопее он ведет себя иначе?
Ответы 1
Это не потому, что вы используете эпики. В первом примере используется .merge(Observable.of({ type: "C" })), поэтому он подписывается на Observable.of({ type: "C" }) сразу же, что и вы подписываете на epic1. Однако вы используете redux, поэтому подписка происходит где-то внутри redux, а Observable.of({ type: "C" }) излучает немедленно, даже не зная, когда это произошло. Тогда любое другое действие .ofType("A") не вносит изменений, потому что .merge(Observable.of({ type: "C" })) уже передал свое единственное значение.
Это также объясняет, почему пример, который вы упомянули в конце своего вопроса, работает должным образом.
С другой стороны, когда вы используете mergeMap, обратный вызов вызывается при каждом выпуске наблюдаемого источника (при каждом действии action$.ofType("D")). Он создает новые действия E и F, которые немедленно объединяются в цепочку.