问题标签 [rx-java2]

我在看一个用 MVP 编码的 android 应用程序的例子（链接在这里）。但现在我想将教程中给定的 RxJava1 代码重新编码为 RxJava2 代码。但是，我遇到了麻烦，尤其unSubscribe()是isUnSubscribed(). 我试图转换它，我会分享我的尝试。

RxJava1 代码：

这是我对 RxJava2 代码的尝试：

我对 RxJava 的概念相当陌生。如果有人能指出我的错误并指导我，那就太好了。:)

我正在尝试使用 Retrofit 2 创建天气应用程序，现在我很难正确设置呼叫。

这是有效的 URL：

所以，我有我的 API 密钥和 BASE URL 是：http ://api.openweathermap.org .. 这是我改造服务中的方法：

我得到的错误是：

java.lang.IllegalArgumentException：URL 查询字符串“q={city}/&APPID={api}”不能有替换块。对于动态查询参数，使用@Query。

所以我尝试这样：

我得到了同样的错误......任何人都知道这里有什么问题，我的网址有什么问题？

多播 Singles、Maybes 和 Completables 的推荐方式是什么？是否只是建议将它们变成标准的 Observable 来多播它们？

我有点惊讶没有ConnectableSingle,ConnectableMaybe和ConnectableCompletable。这背后的原因是什么？只是不值得努力开发吗？

我正在关注本教程https://youtu.be/YoSr5mi5kKU?t=30m52s以了解 Android 中的 RxJava 和 MVP 模式。

但是，当它到达观察对象的时刻时，它现在起作用了：

错误是：无法解析方法 'subscribe(anonymous rx.Subscriber)'

服务接口是这样的：

我不知道我到底错过了什么或做错了什么。

摇篮进口：

我使用 RxJava 1 已经有一段时间了，但我想看看 RxJava 2。在 RxJava 1 中，我可以按如下方式发出列表的每个项目：

但是，如何使用 RxJava2 实现相同的功能？我尝试使用以下内容，但似乎无法超越以下内容：

我有一个可观察的，它发出一个具有两个字段的对象，如下所示：

现在，我想知道：这个 observable 可以以某种方式分成两个 observable 吗？我想做的是让一个订阅者收听s link，另一个收听Comments 。

我有一个列表，我想根据一些谓词对其进行过滤，这可以通过RxJava使用过滤运算符的 ' ' 轻松完成，但我在 Agera 中找不到等价物，文档也不清楚。

使用 rxjava 1.xi 时用于返回Observable<Void>处理来自改造的空响应：

但是由于 rxjava 2.x 不会发出任何东西，Void有没有什么好的做法来处理那些空响应？

RxJava 库曾经有一个已停产的并行运算符，但是当前的 Spring Reactor 项目有一个并行运算符

是什么阻止了 RxJava 实现并行运算符？

我可以看到有一个名为RxJavaParallel的项目正在尝试执行此操作，但我无法理解为什么以这种方式处理它？当前的 RxJava 实现是否存在固有的设计限制，这使得它变得更加困难？

更新

我希望解决的问题

@akarnokd 指出的这个PR正是我想要的！想知道为什么它一开始就不在那里:)

更新

感谢@akarnokd 的链接和回复，我想正是这种态度让图书馆对像我这样的人来说很简单。如果您在主 RxJava 项目中找不到所需的功能，扩展项目值得一看

我的应用程序中有一个用例，用于从服务器下载两个 zip 文件。为此，我一直在使用改造+rxjava（创建了两个单独的改造服务）。对于并行执行，我一直在新线程中订阅改造服务，然后使用 zip 运算符将其组合起来。它工作正常。但后来我将地图运算符添加到这两个服务以进行解压缩操作，但它没有执行在地图运算符中编写的代码，并且控件直接传递给 zip 操作。我不知道如何解决这个问题，我是反应世界的新手。

到目前为止我已经尝试过什么

和 getObserver() 函数

当代码执行时，控件被转移到 zip 运算符中的 apply() 函数，并且两个 observable 中的 map 运算符都没有被执行。

还有一个问题

我正在合并/压缩两个 observables，传递给操作员的类型是 Response<"ResponseBody">。实际上我需要那里下载的文件路径（字符串类型），为此我该怎么办？

**

更新了@Yaroslav Stavnichiy 描述的解决方案，现在它可以工作了

**