rx-java2 相关问题

我无法设置从API到数据库的列表

我使用NetworkModule模块中的Retrofit从API获得列表。现在，我想使用RxJava而不使用AsyncTask将结果列表安装在Room数据库中。但是在我的insertAll ...

RxJava“ Robelectric测试案例失败” java.lang.AssertionError：位置0的值不同；预期”

我的测试用例在测试我的会议室数据库时失败。这是充当房间数据库和我的存储库类之间的中间类的类...类Cache @Inject构造函数（var newsDb：...

根据上一个API调用的结果进行RxJava调用的最佳方法

我正在进行API调用以获取节目播客的描述，并且基于播客的类型，我可能也可能不必执行另一个API调用来获取更多信息。我是RxJava的新手，我是...

为什么从休息端点返回它时渴望观察到的行为？

@@ GetMapping（value =“ / list”，产生=“ application / json; charset = utf-8”）public Observable > allPerson（）{return Observable .range（0，Integer .... ] >

应该配置rx-java吗？

如果我有这个rxjava链：Observable.create {...} .firstElement（）.subscribe（{...}，{...}）经过实验并查看了源代码之后，它看起来像firstElement（）自动...

无法使用RxJava2导入SyncOnSubscribe

我正在尝试使用SyncOnSubscribe，但显然不包含在// https://mvnrepository.com/artifact/io.reactivex.rxjava2/rxjava编译组：'io.reactivex.rxjava2'，名称：'rxjava '，...

RxJava将Single与Completable结合使用

我对如何正确使用Single和Completable感到困惑。我有一个get方法，该方法返回Single，另一个方法只是保存数据，不返回任何内容（Completable），代码如下：...

我为什么不能向此Observable添加观察者？

以下是我的代码，我在本文中遵循：public static final String BASE_URL =“ https://newsapi.org/”;公共静态最终字符串ENDPOINT =“ / v2 / top-headlines”;公共...

RecyclerView列表的无限更新

借助dagger和rxJava，我在RecyclerView中更新了列表。一切正常，显示列表。但是问题是，在日志中，我看到了此列表的每秒更新方式。 ...

通过按后退按钮关闭应用程序时取消Retrofit + RxJava调用

我有一个库模块，正在使用retrofit2和RxJava进行网络调用。在应用启动时进行呼叫，并在成功后显示吐司消息。启动应用程序后，如果我关闭...

RxJava-有点复杂的API请求，以及进度的详细信息

首先，我只使用RxJava / RxAndroid玩了几天。在psuedocode中，当我从Guild Wars 2 API加载数据时，我正在尝试完成以下操作：...

如何使用Rxjava预先填充android房间数据库

如何使用Rxjava正确地预填充数据库，这是我的dao @Query（“ SELECT * from where where where困难=：difficulty”）Flowable > getQuestions（String ...

RxJava-如果其中一个可观察对象引起错误，如何使平面图继续？

如何对Flowable.interval进行单元测试？]

我在演示者内部有以下代码。公共类SignUpPresenter实现了Presenter {私有CompositeDisposable一次性用品；私人视图视图； @Inject public ...

ViewRootImpl $ CalledFromWrongThreadException rxjava setVisibiltiy through rxjava

[大家好，我目前在RXJava中遇到线程问题。我想通过rxjava设置可见，但是android抛出了这个异常“ ViewRootImpl $ CalledFromWrongThreadException”一次性...

如何使用doOnNext，doOnSubscribe和doOnComplete？

RxJava2 / RxAndroid和Android开发的新手，但对Java非常熟悉。但是，在尝试“优化”并能够在一堆...

如何在具有不同对象类型的房间中创建可流动交易？

我想为此搜索我的应用程序，我想根据它们的名称同时查询两个表，并且只要它在...中找到相关名称，就想返回结果。 [

RxJava2 CompositeDisposable可以自行清理已处置的订阅吗？

[我有时会为网络请求触发一个Single，如果需要取消所有未决的网络请求，我会将该事件添加到CompositeDisposable中。 CompositeDisposable将添加一个...

RxJava2 Flowable：将对象一一发送到服务器并检测结束

我需要将对象列表发送到我的远程服务器。因为它们可能很多而且很大，所以我使用flowable使用request（1）从arraylist一对一地发送它们。对于每个对象，改型调用为...

RxJava /响应中的每个项目的改造调用

我使用Retrofit / rxJava调用我的API，并且得到了类似ObedDog列表的Observable响应。您可以看到我的代码：CompositeDisposable.add（breedDogsDisplayDataRepository.getBreedDogs（name）...