与RxJava2相关的任何内容 - JVM的RxJava Reactive Extensions的新实现 - 一个使用Java VM的可观察序列组成异步和基于事件的程序的库。
为什么RxJava Completable发射器中的Firebase任务不执行？
我正在开发连接到Firestore的Firebase Android应用程序。术语是该集合为“资产”。示例代码具有简单的操作，例如addAsset和deleteAsset，...
我的设置是以下活动：onCreate（捆绑保存的InstanceState）{myViewModel.getData（intent.getParam）.observe（this，this :: dataDisplay）; } ViewModel getData（String param）{return ...
我在我的存储库实现中遇到了一个奇怪的问题。每次我调用应该从数据库获取数据并通过网络调用更新数据库的函数时，都会收到...
Room + RxJava 2如何检查表中的列等于特定值的记录
我有一个用户表。我需要检查是否存在具有特定名称的用户。我正在使用此代码UserDao @Query（“ SELECT * FROM User WHERE userName =：userName”）来完成此操作。getUserByUserName（...] fun>
我一直在尝试学习如何使用RXJava，我想知道如何更改下面的AsyncTask代码并使用RXJava。我是RXJava的新手，并且由于不赞成使用AsyncTask，所以我...
我一直在尝试学习如何使用RXJava，我想知道如何更改下面的异步任务代码并使用RXJava。我是RXJava的新手，并且由于不赞成使用AsyncTask，所以我...
所以我知道这已经被问过很多次了，但是我尝试了很多事情，但似乎没有任何效果。让我们从这些博客/文章/代码开始：https：//blog.danlew.net/2016/01/25/rxjavas -...
我需要在收到事件后的X秒内执行一些操作（代表任何数据项rxJava）。但是，如果在X秒结束前又发生了另一个事件，则计时器重置并需要再次执行操作...
我想知道Schedulers.io（）是否将按照调用者的顺序执行任务。公共类SaveTest {@Inject private MyRepository myRepository; public void save（）{...
使用RxJava2类型返回的更新查询会给出错误：不确定如何将Cursor转换为该方法的返回类型
这里是给出游标转换问题的代码片段：@Query（“ UPDATE profile SET profilePicture =：newProfilePicture WHERE firstName =：first AND lastName =：last”）有趣的...
Android Retrofit + Rxjava flowable太早完成
我正在尝试从Spring RestController向使用Retrofit和Rxjava的Android应用程序发送io.reactivex.Flowable。如果使用浏览器检查Rest端点返回的内容，则会得到一个...
我正在使用RxJava3进行改装，但无法获得RxJava3的rxjava3改装适配器。] >>
如以下代码所示，我想使用RxAndroid。但是我面临两个问题：1-我想将Array转换为Observable，但是无法识别方法.fromArray 2-为什么在...
RxJava ConcatArrayDelayError和过滤器：仅在两个源均失败时才返回错误
我是RxJava的新手，经过几天的尝试，我可以在网上找到所有东西，我发现我确实需要这一方面的帮助。我从本地和远程源中获取资源库中的成员。我添加了...
RxJava2中是否有doAfterSubscribe等效项？
我有一个观察到的流对所有请求的响应。我想在发出请求时创建一个可观察的过滤器，以便可以与多个订户共享输出。 ...
我想使用翻新功能同时拨打多个电话。当两个电话都结束时，我想对结果有所帮助。这是我的接口公共接口IService {@GET（“ all”）...
考虑到我有一个对象List ，而我试图将这个对象转换为List 。我能够为单个对象执行此操作，但是在这里面临解析列表的困难。 ...
将Flowable分成2个，处理2个流，但是一个依赖于另一个？
我有以下情况：我需要处理以Flowable形式接收的流。流上的每个项目都有一条数据，只有流上的第一个元素包含元数据。 ...
如何在lambda和ObservableSource中使用concat
RxJava2 kotlin可以，我可以连接2个可观察对象Observable.concat（countries（），animals（））.subscribeBy {println（it）} ...