RXJS + Redux Observable - 如何合并一个新流？
RXJS + Redux Observable - how to merge a new stream?
我们最近选择了 Redux Observable，它是管理高级动作编排的好方法。
我最近遇到的一个问题是响应数据获取的结果。我们有一个通用服务函数，它 return 是一个 RXJS 可观察对象。通常我们 select 我们需要和订阅任何数据。
我认为这对于 redux-observable 来说是相当自然的。在 Epic 上使用 MapTo，return RXJS 观察器以及随后的 select.
据我所知，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'，这导致了冲突。
谢谢大家
我们最近选择了 Redux Observable，它是管理高级动作编排的好方法。
我最近遇到的一个问题是响应数据获取的结果。我们有一个通用服务函数，它 return 是一个 RXJS 可观察对象。通常我们 select 我们需要和订阅任何数据。
我认为这对于 redux-observable 来说是相当自然的。在 Epic 上使用 MapTo，return RXJS 观察器以及随后的 select.
据我所知，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'，这导致了冲突。
谢谢大家