rx-java2 相关问题

与RxJava2相关的任何内容 - JVM的RxJava Reactive Extensions的新实现 - 一个使用Java VM的可观察序列组成异步和基于事件的程序的库。

RxJava PublishSubject 缓冲区元素超时

我想用RxJava实现以下目标: 缓冲元素并在最后一个元素过去 5 秒后发布它们 在第一个元素之后的 20 秒内发布缓冲元素 呃...

回答 1 投票 0

使用 Cucumber 和 RxJava 在 AndroidTest 中进行活动清理

我在黄瓜测试结束时观察到一个奇怪的堆栈跟踪。 我的测试基于 cucumber-jvm android 示例。我使用 RxJava2 在 @Then 方法中执行一些异步过程。没有异步进程,我...

回答 1 投票 0

RxJava:如何在将其发送给观察者之前仅修改第一项

我有一个 Rx 流,它向观察者发送多个项目。 但我想修改发回的第一个项目。所有其他项目都可以按原样发送。 我知道 map() 会介入...

回答 2 投票 0

Android中OkHttp拦截器如何处理IOException?

我有一个自定义拦截器,可以将 API 密钥附加到所有 API 请求中。这是代码: 公共类 HeaderInterceptor 实现拦截器 { 私有最终 ProfileDbDataSource

回答 2 投票 0

如何使用依赖于第一个可观察数据的第二个可观察数据更新第一个可观察数据

在Android中使用Retrofit结合RxJava我得到一个Observable对象。里面我有一个清单;在表中,我有包含来自对象 Product 的外键的属性。 我的目标是获得

回答 1 投票 0

Observable.fromCallable() 方法内部没有被调用

这就是我使用 Observable.fromCallable() 的方式。在其他班级中它工作正常,但在某些班级中则不然。任何帮助,将不胜感激。 可观察的 .fromCallable(() -> 开始工作...

回答 1 投票 0

在 RxJava 中组合 2 个数据源,可以从 1 个可观察量中获取新数据

我目前正在开发一个 Android 应用程序,我在 ViewModel 中使用 RxJava 来处理来自本地 Room 数据库和远程 API (Retrofit) 的数据。我已经实现了拉动刷新功能...

回答 1 投票 0

无法为 io.reactivex.Observable 创建调用适配器

我将向我的服务器(它是 Rails 应用程序)发送一个简单的 get 方法,并使用 RxJava 和 Retrofit 获取结果。我所做的事情是: 我的界面: 公共接口 ApiCall { 字符串

回答 4 投票 0

在简单情况下使用响应式编程的原因

请有人解释一下使用反应式的优点是什么: Observable 问候 = Observable.just(“你好”); Observable 大喊大叫=greeting.map(s -&g...

回答 5 投票 0

用 RxJava2 替换 AsyncTaskLoader 的最佳方法是什么?

我是 RxJava 的超级初级者,如果有更好的方法,我可能需要找到更好的方法。 我正在研究遗留的 Loader 代码,我想用 RxJava 替换它。我的

回答 1 投票 0

映射器函数返回空值

我为调试和发布设置了相同的构建类型, 构建类型{ 调试{ buildConfigField "String", "API_BASE_URL", "\"https://www.testUrl.com/api/\"" minifyEnabled true

回答 2 投票 0

预期的 begin_array 但在 Kotlin+Android 上第 1 行第 2 列路径 $ 处是 begin_object

我调用了PetFinder API来获取数据。当我想在屏幕上显示数据时出现此错误。我使用调用序列来获取数据,并在 ViewModel 上使用排队 我尝试使用 fromJson() 遇到...

回答 1 投票 0

创建一个不会在完成或错误时终止的 RxJava 主题

我正在尝试创建一个可以订阅 Observable 的 RxJava 2 Subject,但当订阅的 Observable 由于错误或完成而终止时不会终止。 本质上,这...

回答 3 投票 0

Single 中 DB 操作的返回值<Long>

我在我的数据库(房间)中添加一条记录,它返回插入记录的 ID。例如,我添加一行并返回数字 5(这是一个 Long)。 当该操作完成时,我 n...

回答 0 投票 0

如何使用 Flowable 和 Single 并行运行一组可调用对象

我有 4 个阻塞操作,我想使用 RxJava Single/Flowable 并行运行它们。 我编写的用于检查并行性的测试代码是: 最终单 f1 =单.

回答 0 投票 0

如何从 Flowable 中删除存在于第二个 Flowable 中的元素?

我需要保存一些数据做数据库。 我有从服务器获取的数据的 Flowable,以及来自我的数据库的数据的 Flowable。 我只需要保存数据库中尚不存在的数据。 我试着去...

回答 0 投票 0

使用 Spring WebClient 的内存泄漏

我想遍历域名列表(数百万条记录),发送请求并接收响应,以确定它是否存活。 我选择了一种被动的方法,我

回答 2 投票 0

RxJava - 如何避免这种竞争条件?

我正在尝试在后台线程上将一些数据插入到本地数据库中,并在我的 ViewModel 的构造函数中使用 Completeable 公共 MainViewModel() 扩展 ViewModel { 公开

回答 0 投票 0

Rxjava - 组合 Singles 并生成数据类 Single

我有一个关于单身的问题,但还没有找到一个好的答案。 我必须从获得 2 个 Single 源的方法中返回 Single。问题是我需要使用输出...

回答 1 投票 0

无法使用 TestSubscriber 订阅 RxJava 2 Observable

为什么我的编译器不允许我使用 TestSubscriber 订阅 Observable? 这是我的代码: TestSubscriber testSubscriber = new TestSubscriber<>(); Observable.ju...

回答 3 投票 0

© www.soinside.com 2019 - 2024. All rights reserved.