RXJS REDUX可观察 - 如何合并新流



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

我最近一个问题是响应数据获取的结果。我们有一个通用的服务功能,可以返回可观察到的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); }

此代码实际上是正确的。依赖性使用的是" rx"库,而不是造成冲突的" rxjs"。

谢谢所有

最新更新