与RxJava2相关的任何内容 - JVM的RxJava Reactive Extensions的新实现 - 一个使用Java VM的可观察序列组成异步和基于事件的程序的库。
RxJava2:调用Flowable.toList时处理null
我有以下要求:遍历数组,并为每个元素发出一个方法,该方法有时可以返回null并最终将所有结果收集到一个列表中。这是一个摘要:public Single&...
我试图在服务器上成功发布数据后,使用Retrofit2和rxjava2在服务器上发布数据,我想从服务器获得响应。我正在使用kotlin,因此如何在我的应用程序中获取服务器响应。 ...
是否有一种方法(运算符)来缩小/增强下面的代码?我想采用Observable的第一个元素,但要延迟其完成,直到源代码完成为止(这就是为什么我选择concat ...
从RxJava嵌套链内的LiveDataReactiveStreams.fromPublisher()发布多个结果
让我们从一个基本示例开始,假设我有以下代码块,用于从存储库私有fun getToken()中获取Auth令牌:LiveData {返回...
是否有一种方法(运算符)来缩小/增强下面的代码?我想采用Observable的第一个元素,但要延迟其完成,直到源代码完成为止(这就是为什么我选择concat ...
我正在尝试对单个实体进行简单的CRUD测试,但是我无法弄清楚自己做错了什么,因此测试始终会因AssertionError失败。这是我的数据库设置:@Database(...
RxJava运算符,如replay(1,1,MINUTE),但经过1分钟后重新订阅
我需要一种可能会认为相对简单的缓存过期机制(例如1分钟)。当第一个订阅者订阅时,我想进行API调用。当第二个人在几分钟之内订阅时,请不要...
实现MVVM LiveData RxJava Dagger数据绑定的正确结构?
MainActivity类MainActivity:AppCompatActivity(){@注入lateinit var mainViewModelFactory:mainViewModelFactory私有lateinit var mainActivityBinding:ActivityMainBinding ...
如何在不通过调度程序调用的情况下进行改造创建Observable?
我正在研究rx-java和改造,我对此有一些疑问。我不明白,当我们调用下面的代码时,如何创建Observable(Observable)呢?根据我的...
我已经走过了跨以下要求:我有一个返回值可能的方法,我需要处理它的远,如果它返回的东西,然后调用返回单另一种方法,...
RxJava调用返回NetworkOnMainThreadException而我已经设置subscribeOn(Schedulers.io())
根据我RxJava,那么SendMessage(的underestanding)必须在后台IO线程执行及其结果看到在Android主线程。然而,sendMessage()方法似乎是在Android上运行的主要...
我从2个数据库表和重复删除后根据他们从第三个表中读取取值。我的示例代码:db.select(“从表1选择ID”).getAs(字符串....
我一直在一遍又一遍地阅读文档再次,我无法找到合适的运营商对我的情况:返回Observable.fromIterable(formIds).flatMap(新功能&...
如何在Android应用程序结合起来,RxJava网络和数据库更新
我调查我的最新的Android应用中使用RxJava的。我有相关的更新的数据库模型的两个列表对象ListDB1和ListDB2我试图实现逻辑是...
是否有任何RxJava2运营商可以从可流动的应用转换为单或可能?我的意思是Flowable.compose()经营者申请一个变压器可流动并返回另一个流动的。 ...
我访问使用也许数据库,我的目标是呼叫网络,如果可能将完成,表明存在数据库中没有数据(我用的房间)。我有以下功能:@Override ...
我是新来RxJava,寻找我的Android应用程序中的网络和数据库处理它非常有用。我有,我不能在RxJava使用案例1清除完全实现了两个用例...
客房内的数据库,我想添加一些观察者,其中通知是这样的:删除,插入,更新。我没有那种实现通过创建一个接口,适配器实现它。所以,每一次...