at subscribeTo (subscribeTo.ts:28)
at subscribeToResult (subscribeToResult.ts:37)
at RetryWhenSubscriber.error (retryWhen.ts:74)
at MapSubscriber.Subscriber._error (Subscriber.ts:144)
at MapSubscriber.Subscriber.error (Subscriber.ts:114)
at subscribeToPromise.ts:15
action$.pipe(
ofType(actions.FETCH().type),
switchMap(() =>
from(ajax.get(url)).pipe(
map(({ data }) => ({
type: 'SET_DATA',
payload: data
})),
retryWhen(errors$ => {
errors$.pipe(
delay(1000),
map(() => {
action.payload.retries -= 1;
if (action.payload.retries === 0) {
throw errors$;
}
}),
);
}),
catchError(error =>
of({
type: 'HANDLE_ERROR',
payload: error,
error: true,
}),
),
),
),
);
I have a question about the forkJoin operator. In this example I want to execute 2 actions that perform ajax calls, and combine their results.
export default action$ => action$.pipe(
ofType(ACTIONS.GET_SETTINGS),
mergeMap(action =>
forkJoin(
of(getSetting(1)), // getSetting returns an action object
of(getSetting(2)),
).pipe(
mergeMap((results) => {
console.log(results[0]),
console.log(results[1]),
return { type: 'store_settings', results};
}),
);
),
);What happens is that in the results I got my 2 actions back, instead of their results (so they are not executed).
Any hints how to adapt my code?
Hello guys,
question: I working on a new project and it uses react and redux-thunk. We want to switch to redux-observables and we want to do it gradually.
As a test case, I transformed one of the store entry into using Epics and it works as expected first than we have some unexpected behavior.
Basically after the action and changes triggered by our epic, the next unrelated action reverts back the state to where it was before our epic fired.
did you guys have any success with using redux-observables and redux-thunk at the same time?
Thank you!
@Mustaflex Redux-Observable and Redux-Thunk work together without issue. One thing to keep in mind is that Redux-Observable runs after reducers whereas Redux-Thunk runs immediately (meaning before reducers).
What's the code you're working with where you're having the issue?
@gardezii
Hi guys, I hope all of you are doing fine. Can you please tell what is it that I'm doing wrong over here ?const createRequest = (ajaxParameters) =>
ajax(ajaxParameters).pipe(
takeUntil([ofType("END")])
)
I'm using rxJs and redux-observables. The problem is if I add takeUntil, it stops triggering all the epics. Any idea what is it I'm doing wrong over here?
I've created an API file in which I'm creating the get, post, put, delete request. All the epic file import the request functions from this file.
https://stackoverflow.com/questions/60752347/adding-takeuntil-stop-triggering-all-the-actions-rxjs-redux-observable
A few people have asked actually. Unit testing epics is pretty simple, but look at RxJS testing to get an idea.
In this case, to test an epic, you're calling a function that takes a new Subject(), a new BehaviorSubject(store.getState()), and potential dependencies that you can separately mock.
Trying to migrate to rxjs6
I've got a error.
Because you're still importing rootEpic. rootEpic2 should at least work by itself. If so, then the issue, like @monojack said, could be related to imports.
Basically, you're importing X when you should be importing {X}. And the error is saying "you passed in an object when you should've passed in an operator".