首页 文章

RXJS Redux Observable - 如何合并新流?

提问于
浏览
1

我们最近选择了Redux Observable,这是管理高级动作编排的好方法 .

我最近遇到的一个问题是响应数据提取的结果 . 我们有一个通用服务函数,它返回一个RXJS可观察对象 . 通常我们选择我们需要和订阅的数据 .

我认为这对于redux-observable来说是相当自然的 . 在Epic上使用MapTo,并使用后续选择返回RXJS观察者 .

据我所知,Redux-observable不订阅所以没有任何反应 .

有没有人有一个如何运作的例子?

export function redirectUserToEndpointEpic(action$) { return action$.ofType(LOCATION_CHANGE) .filter(action=>action.payload.pathname !== '/')) .mapTo(action=>authService.getObserver() // returns a stream which has not been subscribed to .select(userData=>userData.defaultPath) .map(push); }

1 回答

  • 0

    这段代码实际上是正确的 . 依赖是使用'rx'库而不是'rxjs'导致冲突 .

    谢谢大家

相关问题