与RxJava2相关的任何内容 - JVM的RxJava Reactive Extensions的新实现 - 一个使用Java VM的可观察序列组成异步和基于事件的程序的库。
将RxJava Single转换为java CompletableFuture
我有一个RxJava2整数整数，如何将其转换为java.util.concurrent.CompletableFuture？ Single single = Single.just（1）; java.util.concurrent.CompletableFuture
使用用户名或电子邮件地址的Spring boot webflux登录名
我是spring boot webflux的新手，并且正在使用Cassandra作为我的数据库。我不知道如何使用用户名或电子邮件登录。我有三个表用户表创建表用户（userid bigint，...
DataBinding ViewModel vs RxJava 2
所以基本上到目前为止，我一直在应用程序中广泛使用rxjava2，但是决定检查数据绑定，查看模型和实时数据。而且我不确定我是否拥有所有这些权利，...
我正在发出网络请求，并且当出现诸如Internet脱机之类的错误时，它应该向用户显示一个错误，但是会在后台重试，因此当用户自动访问Internet时，它会自动显示...
reversRange（int from，int to）{Stream intStream = Stream .... ] >
如何在RxJava 2中从无限流创建Observable [？
reversRange（int from，int to）{Stream intStream = Stream .... ] >
如何在RxJava 2中从Stream ？]创建Observable ??
我正在尝试将RxJava从1升级到2。在我的旧代码中，我有一个方法reverseRange：private Observable reversRange（int from，int to）{Stream intStream = Stream ....
在ViewPager2中是否有任何解决方案可以使customView平滑滚动，而最初不会平滑滚动
我从后端API获取项目列表，并在Viewpager中水平显示该列表的项目。列表已获取并成功显示在ViewPager中。但是问题是，最初滑动不是...
Observable 具有subscribe（）的对象不显示值
我已经尝试了解rxJava Observable超过一天了，但是我无法弄清楚我的情况需要什么。我认为是因为我不是在创建Observable，而是仅获得一个...
我已经尝试了很多示例，但是对我来说却没有奏效，我只想使用以下代码将分组结果作为列表接收：private final PublishSubject s; ...
我有以下代码可以正常工作。但是，我不喜欢blockingGet。有没有一种方法可以将getSingle（）调用上移到Observable的'global'变量中，以......>
我无法绕过正确的语法来执行以下操作：创建仅执行一次且从不调用onComplete的Hot Observable，让其他Observable监听并响应...
我想知道最干净的方法是使用RxJava语法遍历一个集合，如果不存在任何项，则会引发错误。下面显示了一个混合示例，但理想情况下，我希望所有逻辑...
如何在takeUntil中正确使用withIndex，forEachWhile，以及RxJava？
在我的表达式中，即使takeUntil为true / false，subscribe方法也会发出所有列表项，而当takeUntil为true时，应该停止所有列表项？ Observable.fromIterable（countryResponseList.withIndex（）...
我想对RxJava类Invoice（val dayOfMonth：Int，val amount：Int）执行以下操作，下面是示例monthInvoices：List 以处理Invoice（3,100）Invoice（3,150）Invoice（3，.. 。
Rx Java：OnNext之前休眠（从Observable发射之前休眠）
基于我的Observable中的条件，我想延迟onNext / onError。我的代码如下：fun check3（）{val list = arrayListOf（1,2,3,4,5,6,7，null）val obs = Observable.create
如何正确组合RxJava / Vert.x数据访存器/ GraphQL订阅
我有以下测试代码：FlowableOnSubscribe fos;私人无效init（）{fos =发射器-> {试试{while（true）{SomeObj someObj = ...
我有一个正在运行并扫描BLE设备的服务，通过该服务，我通过知道mac地址为特定设备读取了该设备，现在问题出在我读取框架并通过那些......]
如何使用io.vertx.reactivex.ext.web.client.WebClient的rxSendStream进行字符串的Http POST
我是Vertx和Rx Java的新手。我想执行Http POST，但是我的内容是一个字符串。这是我的代码：Single > single = webClient .post（apiUrl）...