rx-java2 相关问题

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

RxJava2:调用Flowable.toList时处理null

我有以下要求:遍历数组,并为每个元素发出一个方法,该方法有时可以返回null并最终将所有结果收集到一个列表中。这是一个摘要:public Single&...

回答 1 投票 1

使用RxJava发布数据后如何从服务器获得响应

我试图在服务器上成功发布数据后,使用Retrofit2和rxjava2在服务器上发布数据,我想从服务器获得响应。我正在使用kotlin,因此如何在我的应用程序中获取服务器响应。 ...

回答 1 投票 0

采取第一项,但未完成

是否有一种方法(运算符)来缩小/增强下面的代码?我想采用Observable的第一个元素,但要延迟其完成,直到源代码完成为止(这就是为什么我选择concat ...

回答 1 投票 0


从RxJava嵌套链内的LiveDataReactiveStreams.fromPublisher()发布多个结果

让我们从一个基本示例开始,假设我有以下代码块,用于从存储库私有fun getToken()中获取Auth令牌:LiveData {返回...

回答 1 投票 0

RxJava:取得第一项,但未完成

是否有一种方法(运算符)来缩小/增强下面的代码?我想采用Observable的第一个元素,但要延迟其完成,直到源代码完成为止(这就是为什么我选择concat ...

回答 1 投票 0

[使用Rx测试房间插入时测试失败

我正在尝试对单个实体进行简单的CRUD测试,但是我无法弄清楚自己做错了什么,因此测试始终会因AssertionError失败。这是我的数据库设置:@Database(...

回答 2 投票 0


RxJava运算符,如replay(1,1,MINUTE),但经过1分钟后重新订阅

我需要一种可能会认为相对简单的缓存过期机制(例如1分钟)。当第一个订阅者订阅时,我想进行API调用。当第二个人在几分钟之内订阅时,请不要...

回答 1 投票 0

实现MVVM LiveData RxJava Dagger数据绑定的正确结构?

MainActivity类MainActivity:AppCompatActivity(){@注入lateinit var mainViewModelFactory:mainViewModelFactory私有lateinit var mainActivityBinding:ActivityMainBinding ...

回答 1 投票 1

如何在不通过调度程序调用的情况下进行改造创建Observable?

我正在研究rx-java和改造,我对此有一些疑问。我不明白,当我们调用下面的代码时,如何创建Observable(Observable)呢?根据我的...

回答 1 投票 0

如何避免嵌套有可能混合和单一工作时认购

我已经走过了跨以下要求:我有一个返回值可能的方法,我需要处理它的远,如果它返回的东西,然后调用返回单另一种方法,...

回答 2 投票 1

RxJava调用返回NetworkOnMainThreadException而我已经设置subscribeOn(Schedulers.io())

根据我RxJava,那么SendMessage(的underestanding)必须在后台IO线程执行及其结果看到在Android主线程。然而,sendMessage()方法似乎是在Android上运行的主要...

回答 1 投票 0

转换单 >到单 在RxJava2

我从2个数据库表和重复删除后根据他们从第三个表中读取取值。我的示例代码:db.select(“从表1选择ID”).getAs(字符串....

回答 1 投票 0

“加入”观测量的RxJava列表

我一直在一遍又一遍地阅读文档再次,我无法找到合适的运营商对我的情况:返回Observable.fromIterable(formIds).flatMap(新功能&...

回答 1 投票 0

如何在Android应用程序结合起来,RxJava网络和数据库更新

我调查我的最新的Android应用中使用RxJava的。我有相关的更新的数据库模型的两个列表对象ListDB1和ListDB2我试图实现逻辑是...

回答 1 投票 0

Flowable.compose()转变为单次或可能

是否有任何RxJava2运营商可以从可流动的应用转换为单或可能?我的意思是Flowable.compose()经营者申请一个变压器可流动并返回另一个流动的。 ...

回答 1 投票 0

Rxjava - 如何检查是否可能/可观察是正确空?

我访问使用也许数据库,我的目标是呼叫网络,如果可能将完成,表明存在数据库中没有数据(我用的房间)。我有以下功能:@Override ...

回答 2 投票 1

如何通过列表与RxJava迭代和第一个项目进行初步处理

我是新来RxJava,寻找我的Android应用程序中的网络和数据库处理它非常有用。我有,我不能在RxJava使用案例1清除完全实现了两个用例...

回答 1 投票 0

房间数据库观察员

客房内的数据库,我想添加一些观察者,其中通知是这样的:删除,插入,更新。我没有那种实现通过创建一个接口,适配器实现它。所以,每一次...

回答 2 投票 0

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