Closed thorbenandresen closed 8 years ago
Hello @Thorbenandresen,
Your example does indeed seems correct to me.
export default iterable => iterable
.filter(({ action, state }) => action.type === 'Boot')
.flatMap(() => Observable
.fromPromise(new Promise(res => res()))
.map(() => ({type: 'BAR', data: []})));
Here's my code which WFM.
Maybe you could provide more complete example?
@tomkis1 - thanks, I found my mistake. I was using import {Observable} from 'rx'
instead of import {Observable} from 'rxjs'
. (importing from 'rx' works in my thunks where I use Observables, thats why I was misled) Sorry for that!
Hi,
this here works for me
this here does not work
I am still trying to wrap my head around sagas+rx, but based on this example it should work, right?