问题标签 [rx-java2]

For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.

0 投票
2 回答
313 浏览

rx-java - 在 rxjava 2 中找不到 OnErrorThrowable

我正在将 rxjava 1 升级到 rxjava 2。在 rxjava 1 中有 OnErrorThrowable,但在 rxjava 2 中没有。在下面的代码中我可以做什么来替换 OnErrorThrowable?

0 投票
4 回答
8657 浏览

rx-java - 无法解析 rxjava 2 中的方法 Observable.from

在 rxjava 1 的 Observable 类中有一个 from 方法,但在 rxjava 2 中找不到。如何在以下代码中替换 rxjava 2 中的 from 方法:

0 投票
1 回答
1116 浏览

java - Rxjava2 + Retrofit2 + Android。进行数百次网络调用的最佳方式

我有一个应用程序。我有一个大按钮,允许用户一次将所有数据同步到云端。允许他们再次发送所有数据的重新同步功能。(300 多个条目)

我正在使用 RXjava2 和 retrofit2。我的单元测试只需要一个调用。但是我需要进行 N 个网络调用。

我要避免的是让 observable 调用队列中的下一个项目。我正处于需要实现可运行文件的地步。我看过一些关于地图的信息,但我还没有看到有人将它用作队列。此外,我想避免一个项目失败,它会报告所有项目都失败,就像 Zip 功能一样。我应该只做跟踪队列的讨厌的管理器类吗?或者有没有更清洁的方式来发送数百件物品?

注意:解决方案不能依赖于 JAVA8/LAMBDAS。事实证明,这比合理的工作要多得多。

请注意,所有项目都是同一个对象。

我的帮手收集和发送我所有的物品

我的改造东西


更新。我一直试图将此答案应用于运气不佳。今晚我已经筋疲力尽了。我正在尝试将其作为单元测试来实现,就像我对一个项目的原始调用所做的那样。看起来使用 lambda 可能有些不对劲。

结果是..


编辑。不再尝试 Lambda。即使在我的 mac 上设置了路径,javahome 指向 1.8 等,我也无法让它工作。如果这是一个较新的项目,我会更加努力。然而,由于这是一个由 web 开发人员尝试使用 android 编写的继承的 android 应用程序,所以它不是一个很好的选择。也不值得花时间让它工作。已经进入了这项任务的日子,而不是应该花费的半天。

我找不到一个好的非 lambda 平面图示例。我自己尝试过,它变得一团糟。

0 投票
1 回答
429 浏览

rx-java2 - 为什么不总是在 rxjava2 中使用 Flowable

在 rxJava2 中,Observables(非背压)和 Flowables(背压)之间存在区别。https://github.com/ReactiveX/RxJava/wiki/What's-different-in-2.0#when-to-use-observable给出了使用 observables 的一些理由,但据我所知,observables 的功能是流动性的子集。

有什么理由不总是使用 flowables 吗?可观察对象可能更快吗?或者你能用 observables 做一些你不能用 flowables 做的事情吗?

0 投票
2 回答
3168 浏览

filter - Observable 中的过滤器不能应用于 Rxjava 2 中的函数布尔值

以下代码中的过滤器试图过滤掉奇数,但我无法编译代码,因为它在抱怨

错误:(114, 25) 错误:不兼容的类型:> 无法转换为 Predicate

当我将 rxjava 1 与 Func1 一起使用时很好,我怎样才能使它与 rxjava 2 一起使用?

0 投票
1 回答
184 浏览

observable - RxJava 2:关于因 BackPressure 而丢弃的消息的统计信息?

我正在使用带有 DROP BackPressure 策略的 RxJava 2 Flowable。有什么方法可以收集有关由于 BackPressure 而实际丢弃了多少消息的信息/统计信息?

解决方案

Flowable#onBackpressureDrop(consumer -> {}); http://reactivex.io/RxJava/2.x/javadoc/io/reactivex/Flowable.html#onBackpressureDrop(io.reactivex.functions.Consumer)

0 投票
2 回答
2613 浏览

android - RxJava出错后如何更改重试请求中的参数

我使用改造 2.0 向服务器发送登录请求,服务器返回客户端会话令牌,我必须在其他请求中使用它,但这个令牌的生命周期有限,当它过期时服务器返回 HTTP 错误 401。

在收到此错误后,我尝试重新登录,并在下一个代码的帮助下:

并发送重试请求,但请求参数与错误请求相同(重新登录前)。在再次发送之前如何更改请求的参数?

0 投票
1 回答
77 浏览

flatmap - 修改平面图函数中的列表时出现不支持的异常

尝试从 RxJava2 中 flatmap 的“应用”方法内部修改列表时,我得到一个不受支持的操作异常。

但是,如果我创建一个新列表,它可以正常工作,如上所示。关于它的任何见解?

下面是我的 Observable 创建逻辑:

0 投票
2 回答
1482 浏览

android - RxAndroid Release Apk 不适用于 build 25.0.2

我也已经在rxandroid 问题页面上发布了这个但没有响应它已经 4 天但没有响应,问题是在调试 apk rxjava 功能按预期工作,但在发布 apk 中,只有与 rxjava 或 rxandroid 相关的功能根本不工作

build.gradle(项目)

build.gradle(模块)

程序:

网络调用消失时的堆栈跟踪:

更新: 据我所知,我在我的工厂类 Retrofit 中使用基本身份验证,我认为问题在于基本身份验证,但我无法修复它。

任何可能的解决方案?

0 投票
0 回答
712 浏览

android - 如何使用 Retrofit2 上传图片?

我知道 Stack Overflow 上有很多问题/答案,但是没有一个能解决我的问题。我查看了所有这些内容,例如如何在 Retrofit 2 中上传图像文件,但无法使其正常工作。

一个大问题是我什至无法--> END POST在终端中看到,这是我在调用 API 后得到的:

这是我的界面:

这是我的服务类:

最后这是我的网络模块:

用户可以单击他的头像以从图库中更改它。onActivityResult()我在我的片段中找到了路径:

依赖项: