问题标签 [redux-observable]

可观察的。

在我的史诗中，我只想调用一个 3rd 方库来安排 iOS 上的推送通知（我正在使用 react native）：

这工作正常，但我想知道这是否是最常见的返回 Observable 并在其中调用的方法observer.next()？

嗨，我正在尝试将 redux-observables 与 react native 和一个名为 Phoenix 的 websocket 包装器一起使用，它基本上允许您在通过 websocket 接收到某些消息时执行回调。

这是我正在尝试做的基本设置：

如您所见，这种方法有几个问题/问题：

1. 一位观察者正在触发不同的事件。.map()除了函数中的 switch 语句之外，我不知道如何将它们拆分

2. 我不知道在哪里打电话，observer.complete()因为我希望它继续监听所有这些事件，而不仅仅是一次。

3. 如果我可以将常量提取channel到可以解决这些问题的几个史诗的单独文件中。但是，channel是依赖于socket，哪个是依赖于user，来自于redux状态。

所以我对如何解决这个问题感到很困惑。我认为提取全局channel对象的能力可以解决它，但这也取决于来自 redux 状态的用户 ID。任何帮助表示赞赏。

PS 如果值得的话，我的用例与这个人非常相似（https://github.com/MichalZalecki/connect-rxjs-to-react/issues/1）。其中一位响应者建议使用Rx.Subject，但我不知道从哪里开始......

我有一个 flatMap ，目的是发出两个动作：

但是，takeUntil是在错误的位置。它在TAP_CANCEL发射时取消了整个史诗。相反，我只希望它取消内部动作的发射flatMap。我该怎么做？

=== 更新 ===

我愚弄了它，这似乎有效？但我不喜欢有 2 个计时器：

我目前从承诺转换为可观察的。我正在为我的反应应用程序使用 Redux-Observable。基本上，我正在寻找能够启用多个并发 ajax 调用并在所有可观察对象成功完成执行时返回响应的最佳运算符。这是我的应用程序的代码片段。

这是一个简单的 ajax 请求，POST_AD_SUCCESSFUL当响应为 201 时发布给定的广告并调度，否则POST_AD_UNSUCCESSFUL在错误时调度。但问题是我想在有响应时制作后续的 ajax 可观察流。如

如果您向我展示实现这一目标的最佳方式，我将不胜感激。

我正在尝试使用以下方法将我的应用与应用内购买挂钩：https ://github.com/chirag04/react-native-in-app-utils

我有一个史诗，如果它成功，我想发出成功，如果失败，我想发出失败。像这样的东西：

但是我不确定如何编写mergeMap. 有没有办法做到这一点？

我按照文档中的步骤来测试史诗。

但是我失败了，因为稍后收到了第二个动作，如下所示。

所以我想我应该知道调度什么时候完成或类似的事情。我该如何解决这个问题？

我使用 fetch() 和 Rx.Observable.fromPromise 而不是 ajax.getJSON()

这是我的史诗。

我在我的 react native 应用程序中使用 redux observable，如果凭据无效，我想在我的登录屏幕上显示一个 react native 警报对话框。我可以在我的史诗中发出警报，但在史诗中我只能返回一个可观察的，那么如何使用 redux observable 来实现这一点？

• 更新01

验证码：

在 react native 中使用 alert api 只是 1 班轮

有没有计划通过离线特性来增强 redux-observable？如果目前有任何像redux-offline / redux-optimistic提供的行为会很好：在请求失败时恢复存储更改。

最好的方法是什么？我很想将 redux-observable 与这些库中的任何一个结合起来，并在需要时使用它。另一方面，我喜欢使用 observables :)

错误“未定义不是函数（评估'_ajax.ajax.getJSON(getIntervalUrl(response)).interval(10000)')”；

这意味着 ajax.getJSON 没有 .interval 函数，我不知道为什么，知道吗？

也许我在想这个错误，但是我与 redux-thunk 一起使用的一个常见模式是返回一个 Promise，这样当某事完成或失败时，我可以在容器对象中执行一些额外的操作。

以 Thunk 为例：

动作创建者：

连接组件中的某处：

在 Redux-Observable/Rxjs 中是否有一种干净的方式来做类似的事情？基本上从一个动作返回一个承诺，调用一个史诗，一旦 observable 完成返回 resolve 或 reject。