问题标签 [rx-java]

我的理解是 rxjava-android 在单独的线程上执行操作（当提供正确的调度程序时），导致非阻塞操作，但是快速而肮脏的测试似乎证明这是不正确的。

我使用了以下代码片段，在这两种情况下，UI 都被阻止了......

片段 1

片段 2

我在这里错过了什么吗？

我正在寻找一种方法来定义观察者的顺序（？）。

例如，我通过 Retrofit 创建的 Rest API 提供了一个 Observable。

在我的ListView观察Observable中。

我还有一个用于我的 Espresso 测试的 API 包装器，并且我在Observable那里订阅了相同的包装器。这种方式首先调用 API 包装器中的观察者，然后才ListView 调用观察者。

有没有办法在所有其他人完成后强制通知一些观察者？或者类似的事情？

就像是

所以ObserverA会先通知，然后ObserverB才通知LastObserver。

或任何其他方法，我可以找出所有注册观察员何时得到通知和完成。

我试图解决的问题用以下代码表示：

这是此测试的输出：

这是我想要的输出：

对于每一种类型 T，都有一个包含 n 个 Observable 的 T 列表，我想构建一个 Observable，每次原始 Observable 中的一个发出某些东西时，它会发出一个包含 n 个 T 的列表。这通常被称为函数文献中的“序列”运算符。

伪语法中的期望行为示例：

我在java中编写了以下幼稚的实现，它行为不端：

不知何故，我需要重建结果列表，而不是将新值附加到现有列表中。你们会怎么做？

感谢您的时间和未来的答案！

rxJava 库是否与 Google Appengine 兼容？如果有，有什么限制吗？我发现的唯一信息是在 grepcode 上提到“部分支持”。 http://grepcode.com/snapshot/repo1.maven.org/maven2/com.netflix.rxjava/rxjava-core/0.9.0

什么不支持？

在自定义应用程序子类中创建 Rx Observables 是否可以接受。这样做的原因是，我可以在应用程序中创建 BehaviorSubject 并每 10 分钟从服务器请求更改一次，订阅此 Observable 的每个 Activity 或 Fragment 将仅获得更改的最后状态。

问题是这种架构在应用程序生命周期处理和易于使用方面是否可以被认为是安全的？

更新： 每次创建新活动并想要获取数据时，它都可以获取 ApplicationContext 的 BehaviorSubject 然后订阅它，Subject 将发出最后一个发出的值；为什么我要这样做？例如，假设您有新闻项目，您获取了新闻提要，并且您想要启动获取新闻项目完整内容的后台任务，在这种情况下，我可以在您滚动新闻列表时开始获取数据，当您单击详细活动时，我们可以从已经获取的显示它，或者只是下载它。

我将多个 Observable 压缩在一起，然后以一种产生 Observable 的方式对其进行转换：

我想做的是：

鉴于 flatZip 不存在（也许我应该提交一个），最干净的方法是什么。目前我不得不将结果放在自身上。

我正在使用 Rx-Java 对数组中的每个项目执行 api 调用。我希望在所有操作完成后调用 OnComplete 操作，但它没有被调用。对数组项的操作确实成功完成。

应用程序 1 向应用程序 2 发送请求。应用程序 2 执行以下步骤并将响应返回给应用程序 1。我想知道应用程序 2 是否可以从使用 RxJava、Reactor 等反应式库中受益。如果可以，请解释一下如何？

1. 将 HTTP Post 请求发送到所有 7 个数据源服务
2. 等待他们的响应并解析所有响应
3. 合并所有回复
4. 返回对 App 1 的响应

我想在此处记录此答案，以解决遇到与我相同的问题的其他人的困惑。使用 rxjava-core 和 rxjava-android 的 v0.18，每当我尝试从 Retrofit 调用返回 Observable 时，我都会收到以下 NoSuchMethod 异常。

java.lang.NoSuchMethodError: rx.schedulers.Schedulers.executor

为什么会发生这种情况，我该如何解决？