与RxJava2相关的任何内容 - JVM的RxJava Reactive Extensions的新实现 - 一个使用Java VM的可观察序列组成异步和基于事件的程序的库。
从RxJava2，如果值相等，我如何比较和过滤两个observable？
我是RxJava2的新手。我试图从缓存和服务器获取Transaction对象的列表。我想比较服务器值和缓存值，如果服务器值相同，那么......
例如，如果我有3个函数Completable requestLogin（）Single hasProjects（）Completable createDefaultProject（）如何在单个请求中组合它们requestLogin（）> onComplete> ...
将值从单个值传递到completable以生成rxjava Android
这就是我想要的：检查我是否有关于数据库中产品的数据。如果我有数据，我运行Single来从DB获取数据。如果不是我运行Single来从后端获取数据如果我得到响应我...
如果没有连接则调用请求的最佳做法 - 每隔4-5秒重复一次呼叫，直到我们得到响应，使用Rx
例如，我们有一些私有的方法getMobileData（）{apiClient.getMobileData（）.subscribeOn（Schedulers.io（））。observeOn（AndroidSchedulers.mainThread（））...
我在Crashlytics上看到以下崩溃：致命异常：io.reactivex.exceptions.UndeliverableException：java.net.SocketTimeoutException：在io.reactivex.plugins连接超时....
试图获取lastLocation，一旦完成，就调用api。但不知怎的，一旦获得位置我的api调用总是在mainThread中运行，所以我得到异常：android.io ....
故意关闭`establishConnection`的`onNext`内的连接并且如果连接丢失，只有错误发生的好方法
如果我正在写一个会重启设备的特性，那么我会遇到一个麻烦的世界。例如。 scanResult.bleDevice.establishConnection（false）.flatMapCompletable {connection ...
我正在用RxJava和Retrofit做我的第一步。我有一个返回Observable的rest API 。类Department具有Team对象的嵌套列表。我怎样才能得到一个Observable＆...
如何从RxJava中的SingleFlatMap中检索整数？
我正在尝试从蓝牙设备中检索值。 if（rxBleDevice.connectionState！= RxBleConnection.RxBleConnectionState.CONNECTED）{rxBleDevice !!。establishConnection（false）？ .subscribe（{...
我不确定究竟要使用什么，但是最近，当我使用包含所有内容流的代码时，我在使用RxJava时遇到了很多麻烦。在我的情况下，让我说我必须得到一个...的实例
我有以下代码：checkZipCode.exec（it）.subscribeOn（Schedulers.io（））。observeOn（AndroidSchedulers.mainThread（））。doOnSubscribe {Timber.d（“主线程：$ {Looper ....
RxJava单元测试 - Observable不会在测试中发出事件
我正在测试一个具有以下定义的视图模型：class PostViewModel（private val postApi：PostApi）：ViewModel（）{private val _post：PublishSubject = PublishSubject ....
我有一个繁重的计算代码：静态类计算机{public Single compute（）{return Single.fromCallable（（） - > {Thread.sleep（1000）; System ....
我有一些字符串的列表，我需要批量迭代列表。示例：val list = [“a”，“b”，“c”，“d”，“e”，“f”] Observable.fromIterable（list）.map {//这里我需要得到......
在Android中运行WorkManager的Worker类中的asyn任务
我是一个工作者，我首先想要在将它上传到服务器之前应用FFMPEG命令。由于Worker已经在后台运行，所以为了保持结果，直到文件上传我已经使用了RxJava ....
我有三个api调用，要求是第二个api和第三个api应该只在第一个成功时被调用。当第一个api抛出异常时，重试那个调用时第一个api ...
我有一个Flowable流将多个流连接在一起：Flowable .empty（）。concatWith（longOperationA（））。concatWith（longOperationB（））。onErrorResumeNext（throwable - > ...
我有一个BehaviourSubject作为我的Retrofit方法的回调。 private val loadCompleted = BehaviourSubject.create >（）在我的改造OnResponse / onFailure中，我打电话给...
无法在Android中使用与Kotlin的Autodispose
我试图使用AutoDispose https://github.com/uber/AutoDispose来处理我在Android中的Rx流。但是当我将它添加到我的活动/片段时，我遇到了一个问题。我认为这是一个kotlin ......
使用Retrofit2和rxjava2在Recyclerview中未设置Gson可转换数据然后订阅它的Give Error：UninitializedPropertyAccessException：lateinit属性数据尚未...