dependabot[bot] on npm_and_yarn
chore(deps): bump debug and moc… (compare)
dependabot[bot] on npm_and_yarn
chore(deps): bump json5 from 1.… (compare)
dependabot[bot] on npm_and_yarn
chore(deps): bump json5, ts-loa… (compare)
dependabot[bot] on npm_and_yarn
chore(deps): bump express from … (compare)
dependabot[bot] on npm_and_yarn
chore(deps): bump decode-uri-co… (compare)
dependabot[bot] on npm_and_yarn
chore(deps): bump qs from 6.2.1… (compare)
dependabot[bot] on npm_and_yarn
chore(deps): bump loader-utils … (compare)
apply
of undefined
. That makes me think one of the epics doesn't exist. If you look at the source of combineEpics
, I'm sure it will say something like Arguments.prototype.apply()
. The only reason this happens is if one of your epics doesn't exist or can't be found for the unit tests.
.apply
in two situations, one for RxJS's merge
function and another for epic.apply
. The latter is more-likely your issue where a passed-in epic isn't a function.
.babelrc
) than your local dev env.
this.schedulerActionCtor is not a constructor
I need help with this error. I get it from epicMiddleware.run(rootEpic)
. Here is the source code - https://github.com/flipflopapp/react-redux-epics-typescript-2021-boilerplate (can anyone help out)
Hey all,
I'm working on an epic that will asynchronously load another epic. While the epic is loading, all actions will be buffered and eventually passed through this epic.
The current implementation I'm working with:
const lazyEpic =
(getEpicPromise: () => Promise<Epic>) =>
(
action$: ActionsObservableType,
store: MiddlewareAPI,
dependencies: BoardEpicDependencies,
): ObservableType<Action> => {
const epic$ = Observable.fromPromise(getEpicPromise());
// Buffer all actions before epic is loaded
const actionsBeforeEpic$ = action$.buffer(epic$);
// Run the buffered actions through the deferred epic
const bufferedResults$ = actionsBeforeEpic$.mergeMap((actions) =>
epic$.mergeMap((epic) => epic(ActionsObservable.of(...actions), store, dependencies)),
);
// Pass the active action$ stream to the deferred epic
const normalResults$ = epic$.mergeMap((epic) => epic(action$, store, dependencies));
return Observable.merge(normalResults$, bufferedResults$);
};
The problem I'm having is this line, which causes a stack overflow/range error, and I can't quite figure out why:
const bufferedResults$ = actionsBeforeEpic$.mergeMap((actions) =>
epic$.mergeMap((epic) => epic(ActionsObservable.of(...actions), store, dependencies)), // Returning epic(ActionsObservable.of(...actions), store, dependencies)) is the culprit
);
Wondering if there's any suggestions or obvious flaws in this implementation?
@dalehurwitz This buffering could be handled by dispatching actions and collecting them in another epic. No need to leave the pipeline and make a bunch of variables.
I'm trying to decipher your epic and can't understand what it's doing. There's no reason to ever call epic(action$, .... etc)
in another epic. Just dispatch an action (that no reducer uses) and be done with it.
export default (action$, state$, { ajax }) => action$.pipe(
ofType(MY_ACTION),
concatMap((action) => {
return ajax.post(/api/...)
.pipe(
switchMap((payload) => {
return of(SUCCES_ACTION(payload));
}),
catchError(() => of(ERROR_ACTION)),
));
}),
);
@bram_hautekiet_twitter That's a tough one. I've solved it a few different ways.
To transmit SUCCES_ACTION
at the end of all these data calls, there are a few ways:
dispatch
first send the number of items, then start the MY_ACTION
listener and count how many outputs you get. Make sure to account for any errors.bufferUntil
and debounce
. This is more complicated, but it's automatic; although, you might still need to mark the source of the data in your action.publish
, but I don't want to get into those unless you really need it. I used this to find out when all downloads were complete when different components were outputting those downloads.action$
.pipe(
ofType('MY_ACTION'),
bufferUntil(
action$
.pipe(
ofType('MY_ACTION'),
debounceTime(YOUR_TIMER_VALUE)
)
),
)
@fisherspy Not being able to apply pipe
to combineLatest
sounds like an RxJS bug.
I think I remember Jay saying something about v2 not having ActionObservable
anymore. But it looks like you're using it for TypeScript types right?
I don't use TypeScript, so I'm not sure nor have I moved to RxJS v7; although, there are definitely others here who have.
ofType
, manually filtering on action.type
etc, it all properly filters the correct action.. ..but I end up with the "..but unknown
!!" errors
It seems like a lot of issues today are related to TypeScript, RxJS 7, and Redux-Observable 2.
I usually answer many of the questions here, but I'm not versed in any of the new stuff nor have I used TypeScript or any recent RxJS or Redux-Observable.
In the past, most questions revolved around "how do I do X in Redux-Observable" which are easy for me to answer. These ones require more knowledge of the technical side of things.
Has anyone gotten the new tech working in their projects?
Im trying to migrate to rxjs 7 and redux-observable v2. The simplest epics are easy to migrate, but I'm having trouble with race
. For example this code:
const waitForGetStuffObservable = race<Stuff.ResponseAction | Stuff.ErrorAction>(
action$.ofType(StuffActionType.RCV_GET_STUFF).pipe(mapTo(Stuff.createResponseAction())),
action$
.ofType(StuffActionType.ERR_GET_STUFF)
.pipe(mapTo(Stuff.createErrorAction(createServiceError({}), q)))
).pipe(take(1))
My own attempt is this:
const waitForStuffObservable = race(
pipe(ofType(StuffType.RCV_GET_STUFF), mapTo(Stuff.createResponseAction())),
pipe(ofType(StuffType.ERR_GET_STUFF), mapTo(Stuff.createErrorAction(createServiceError({}), q)))
).pipe(take(1))
But I just get an error that UnaryFunction
is not assignable to ObservableInput
. Any idea how to fix this?
Hi everybody, does anyone know why the console.log()
is not being printed on the console?
I am new to redux-observable and I am trying to understand how it does work.
Does it have to be with an action that is not being called, If so, how could I call that action in order to execute this console.log()
?
Thanks for your help!!
const getEpic$: Epic<SetOptions, SetOptions, RootState> = (action$, state$) =>
action$.pipe(
ofType(setOption.type),
withLatestFrom(state$),
switchMap(([action, state]) => {
console.log('why is not getting into here?', { action, state });
})
);
@ChristherNand
Epics are functions that return observables, not observables themselves. Put a tap(console.log)
before ofType(setOption.type)
. That will help debug if you're seeing any actions. If you are, then move it down a step until it stops firing.
That should help you debug.