rx-java2

1热度

1回答

我有一个布尔Observable。我只想在当前布尔值与预览不同的情况下发出值（另一个布尔值）。 booleanObservable // which operator here .subscribe(new Consumer<Boolean>() { @Override public void accept(Boolean emitt

0热度

1回答

subscribeOn是如何工作的

我对subscribeOn运营商的工作有些怀疑。我读了一些关于这方面的文章。该observeOn是很容易理解，它只改变downstram，并改变影响所有的downstream。但正如文章subscribeOn can be put in any place in the stream because it affects only the time of subscription.在说：要理

1热度

1回答

RxJava：如何选择正确的调度程序

我正在学习RxJava，我对Scheduler有一些疑问。何时使用哪一个。 AndroidSchedulers.mainThread()是相当简单明了的，当我们需要来到Android UI线程时，我们可以使用这个调度器。但我很困惑，在许多样品我见过pepople使用Schedulers.io()和Schedulers.computation()网络呼叫其他Schedulers Schedule

0热度

2回答

与多个用户一次呼叫流的一部分？

我有用于套接字通信的自定义Rx适配器。在它之外，我观察到Flowable带有消息。然后我有一些经理处理每个消息，然后进一步发布它。 fun observeSocket() = socketManager .observe() .doOnNext{ insideMessageHandler.handle(it) } 然后，我

0热度

1回答

Kotlin：如何将使用Thread.sleep的测试转换为RxJava TestScheduler

我正在编写一个工具测试，它检查是否将某些东西缓存到Rx缓冲区中，并且在某段时间（10秒）后，此Subject将缓冲值插入到我的房间数据库。当我使用Thread.sleep（syncTimeInterval）时，测试是正确的。我想用TestScheduler编写相同的测试。这是用了Thread.sleep版本（通过测试）： @Test fun testMultipleLogs() {

0热度

1回答

HttpException未被onError（）

捕获我正在向使用Retrofit2和RxJava2的后端服务器发出请求。当答案是200或201时，一切正常。当服务器的响应为409或503并且引发HttpException时，它不会被Observable的onError()捕获，并且应用程序崩溃。，我想提出的要求是这样的： @POST("users/sign-up") fun register(@Body register: Register

0热度

1回答

RxJava2在toList之后没有收到doOnNext

我正在开发一个项目，在该项目中，我想在返回结果之前迭代列表并合并它们。基本上我试图将PostResponse对象转换为Post。一些相关的代码。 Post.java public class Post { @NonNull private User user; @NonNull private String title; @NonNull private Strin

0热度

1回答

在RxJava2中没有实现onError错误，即使它实现

因此，我有一个非常基本的RxJava观察器流的工作流，其中我要求改进的东西，成功的响应我吐司成功味精和错误我吐司错误味精。我以下，参照的情况是错误的情况下我期望从API错误味精，我将其转换成用户可读取单词而显示为Toast，如下图所示，当我使用doOnNext和doOnError方法这种方式，与错误崩溃提及。我已经添加了throwExceptionIfFailure方法，它显示了我如何转换可读

1热度

1回答

如何在android房间和rxjava 2中插入数据并获取id作为输出参数？

插入查询 @Insert(onConflict = OnConflictStrategy.REPLACE) long insertProduct(Product product); //product id is auto generated 视图模型 public Completable insertProduct(final String productName) { retu

1热度

1回答

如何使用Flowable.generate从科特林

这里是在Flowable.generate一个失败的短线尝试（与更多类型的注释比我正常使用）： val xs: Flowable<String> = Flowable.generate<Int, String>( java.util.concurrent.Callable<Int> { -> 0 }, io.reactivex.functions.BiConsumer<Int,