rx-java2 相关问题

如何完成当前活动并启动新的活动接收方式？

我想在Rx中执行以下操作。由于finish（）只是排队的异步调用，因此可以确保调用startActivity（intent）：private fun launchNewActivity（）{... finish（）...

Flowable的缓冲结果

我有这段代码可以捕获来自网络摄像头的图像，每秒1张图像。 Flowable.interval（0，1，TimeUnit.MILLISECONDS）.map（aLong-> {BufferedImage bufferedImage = ...

传递观察者并将lambda传递给skipUntil方法

RxJava 2我有以下两个如何使用skipUntil的示例：此示例将lambda函数传递给skipUntil：sourceSubject .skipUntil {... ...>

RxJava的doOnSubscribe在发出之后不早于

我有一个RxJava链，如下所示：Completable.complete（）.andThen（fetchData（））.andThen（fetchAnotherData（））.andThen（...）.doOnSubscribe {/ *一些动作* /} .. 。

仅当满足特定的布尔值时，才使Observable返回

我有这段代码：int finalAttempts =尝试；证书证书= Observable.range（1，次尝试）.delay（3，TimeUnit.SECONDS）.map（integer-> {...

然后将流与RX合并

无法使用Retrofit和RxJava2填充回收器视图

[我正在尝试从服务器获取数据并在回收器视图中显示。我正在使用改造库和RxJava2，但无法从服务器获取数据。它在LogCat中显示总数，但不是...]] >> < [

在多个片段中使用同一观察者，并且仅在可见片段中接收响应，而在后堆栈中不接收响应]]

我正在使用RxJava在我的android应用中访问该API。这里的问题是，如果在两个片段中使用相同的观察者，并且一个片段在堆栈中，另一个片段在顶部，则响应变为...

Vertx Kafka通过明确的轮询自动提交

[一直试图使用Vertx在Java中编写kafka使用者。我需要将自动提交设置为false（特定用例）。下面是执行显式轮询消费者的代码。subscribe（“ test”，ar-> ...

Rxjava超时运算符，仅考虑从特定点发出的项目

我有一个带有一组运算符的rxjava可观察链。假设我有源Observable（总是每分钟发出项目），执行网络请求的操作员B和超时操作员。 ...

Vertx / RxJava / WebClient / ApiGateway / Reactive

我正在使用vert.x和RxJava开发Apigateway。我想发送2 Apis的响应请求，从两个请求中获取响应，并通过HttpServer发送组合的JSON。但是onComplete（）执行到早期...

试图了解subscribeActual（）

这个问题问我想知道什么，但是答案没有解释它。有人可以分享一个具体的示例来说明如何使用subscribeActual（）与subscribe（）吗？

嵌套可完成站点观察者链

我想在flatMap中执行Completable，然后将其“映射”到我需要的特定值。订阅块永远不会执行。为什么？我知道flatMapCompletable和andThen的存在，但是这些...

我如何处理Retrofit + RxJava请求中的错误

我使用MVVM。我有一个功能可以从服务器获取JSON格式的数据。我的存储库中有此功能，如果设备上没有Internet，该如何向用户显示错误，并要求用户... ...>

如何通过订阅方法将Observable.fromIterable中的项目索引传递给onNext？

我正在尝试使用RxJava2加载数据并将其放入SparseArray。我是通过从数组调用URL来获取数据的，但是我需要将响应解析并使用...

Completable.fromAction不执行rjava2中的代码

Completable.fromAction（（）-> startRecording（））。subscribeOn（Schedulers.io（））。subscribe（（）-> {boolean startSuccess = mMediaRecorder.getState（）== MediaRecorder.RECORDING_STATE; ...

我如何将throwable传播到Completable的下一个链？

我正在使用RxJava开发一个Android应用。我有一些API调用链。验证消耗val验证= Completable.error（Exception（“ TEST”））.doOnSubscribe {Log.d（TAG，“ 1. verify”）} ...

RxJavablockingFirst / Single在JUnit 5 Retrofit Test中返回错误的异常

下面的测试应返回HttpException，但它将返回RuntimeException。 @Test fun`Server down会返回500错误`（）{mockWebServer.enqueue（MockResponse（）....

RxJava：将Observable与Completable合并不起作用

我有一个Observable，在某个时候必须将内容写入缓存-我们希望等到写入完成后再在Observable上完成整个操作（出于报告目的……）>

无法在Observable中调用特定的超时重载； kotlin无法匹配参数

我不确定这是Kotlin问题还是RxJava问题，但我倾向于前者。我正在尝试在Observable上调用特定的超时重载，而kotlin编译器不会让我......