rx-java2 相关问题

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

如何测试请求是否增加指标而未在Vert.x中获得任何响应?

我的Vert.x服务器的作业,当它收到一些无效请求时,不会发回任何resposne,而只会增加相关指标。我该怎么测试呢?以下代码不起作用,因为我们......

回答 1 投票 1

Room - 在插入新值后执行Delete

我正在研究Rxjava2,我正在尝试将Room Library与Rxjava2集成。问题是:我有一个填充表,每次我登录应用程序时,我需要删除此表,然后插入...

回答 2 投票 2

使用rxjava的房间有麻烦

我是RxJava的新手,我想知道将RxJava与android机房集成的最佳方法是什么。我已经看到了两种方法:1。@Dao接口UserDao {@Insert void insert(User user); }班...

回答 1 投票 0

Android和RxJava:向Room数据库插入一个Retrofit Response

我有两个稍微不同的问题类。一个是改装调用结果对象,另一个是我的Android应用程序中的Room @Entity。现在我想从我的Interactor类(用例)类做...

回答 1 投票 0

第一个元素之前的RxJava Observable超时

我有设备发送给我ping,我使用observable为此。但在第一次ping之前我们开始连接并且需要一些时间。因此我想先ping有10秒超时。我这样做:......

回答 2 投票 2

kotlin.UninitializedPropertyAccessException:lateinit属性salesGST模型类尚未安装

Json Data使用Retrofit2和rxjav2进行解析。然后它给出了salesNST的lateinit属性的错误:“kotlin.UninitializedPropertyAccessException:lateinit属性salesGST尚未初始化”...

回答 1 投票 0

使用`onBackpressureLatest`删除阻止Flowable的中间消息

我有一个链,在那里我做了一些阻止IO调用(例如HTTP调用)。我希望阻塞调用消耗一个值,在不中断的情况下继续执行,但是丢弃同时堆积的所有内容,然后......

回答 1 投票 0

改造/ RxJava调度程序

我有以下代码行运行网络调用来检索令牌:service.token(initAuth())。blockingGet()而令牌函数具有以下定义:func token:Single

回答 1 投票 0

如何阻止RXJava 2在第一个之后发出更多错误?

使用RX Java 2.2.6。据我所知,当发出单个错误时,整个流停止。但如果发出多个错误,那么我得到......异常无法传递给......

回答 1 投票 0

无法解析方法'sumDouble(io.reactivex.Observable )”

在活动中:Double price = o.getDouble(“totalprice”);可观察 floatObservable = Observable.just(price); MathObservable .sumDouble(floatObservable).subscribe(new ...

回答 1 投票 0

rxjava和rxkotlin有什么区别?

rxjava2依赖项和rxkotlin依赖项之间有什么区别。如果我使用rxkotlin依赖,我是否需要添加rxjava2依赖项。实施'io.reactivex ....

回答 3 投票 4

组合两个observable并将值返回为List,即使一个Observable发出onError也是如此

我正在尝试将两个observable组合成对象列表并在ViewModel中查看它。我是通过使用返回Observable的retrofit函数来实现的 。我想打电话给...

回答 1 投票 0

无法使用gradle 3.0解析rxjava2

Hare是我的应用程序gradle:apply plugin:'com.android.application'android {compileSdkVersion 26 defaultConfig {applicationId“com.example.atumanin.testandroidannotations”...

回答 4 投票 6

java.lang.NullPointerException:第2个元素为null

在活动中:Double [] numbers = new Double [33]; for(int i = 0; i <array.length(); i ++){JSONObject o = array.getJSONObject(i);双倍价格= o.getDouble(“totalprice”); ...

回答 1 投票 0

RxJava - 两个可观察者

我有两个observable - OnPeriodChanged和OnFilterChanged,并试图弄清楚当其中一个更改时如何调用视图适配器的函数。我试过.zip,但出于某种原因,它确实......

回答 1 投票 1

如何在RxJava中执行链任务?

我想逐个在RxJava中执行任务。例如: - 1.从服务器2获取用户ID。通过其ID从服务器获取用户。我试过这个方法public Observable getUids(){...

回答 1 投票 2

在Android中正确模拟和测试交互器类

我有点问题在我的Android应用程序中为我的交互器类设置正确的单元测试。这些类是我的应用程序的“业务逻辑”。这是一个这样的课:公共课......

回答 1 投票 0

RxJava有条件FlatMap清洁方式

我正在寻找一种更清晰的方法来创建一个条件flatMap(),我已经读过这个但是我在我的代码上应用它时遇到了麻烦://为了简单起见给出了变量val stringSingle = ...

回答 2 投票 0

有没有类似Single.empty()的东西

我正在从Rx 1迁移到Rx 2,突然在阅读帖子时我发现Single应该是用于改装调用的可观察类型。所以我决定给...

回答 2 投票 19

何时在Android中使用RxJava以及何时使用Android Architectural Components中的LiveData?

我没有理由在Android中使用RxJava,在Android Architectural Components中使用LiveData。如果两者之间的用例和差异被解释,那将会非常有用...

回答 7 投票 125

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