问题标签 [rx-java3]

我有三个整数观察者，如下所示：

第一观察员：

第二观察员：

第三观察者：

现在，如果我喜欢下面的代码：

Logcat 中没有按照文档中的预期打印任何内容

PublishSubject 仅向观察者发出那些在订阅时间之后由源 Observable(s) 发出的项目。

但是，如果我在创建 Observable 时添加 observable，如下所示并运行它

以下是输出

为什么在这种情况下有任何歧义？

我有一个片段，其中我实现了一些代码：

但是在运行它时，我收到了这个错误：-

我在我的年级中为 rxjava 和 rxandroid 使用这些依赖项

我尝试在我的 mainActivity 中的旧版本 rxjava 和 rxandroid 中运行此代码，它运行完美。

我无法弄清楚问题出在哪里，您能否分享一些关于我可能做错了什么的信息。

有谁知道如何执行以下操作：必须解析元素的内容，并且必须通过并行查询对子元素进行分组只有在先前完成组查询时才应该前进到列表中的下一个项目

我目前使用 rxjava-3.0.3

我有多个Observable<Boolean>来自“警报传感器”的传递数据。他们只提供价值变化。如何等到所有人都切换到false表明不再有警报的情况？

在 Ammonite 中，我执行以下代码...尝试对两个 Flowables 进行有序合并，

但是在打印 2 之后，它会抛出异常：

有人可以帮我吗？我对此一无所知...

奇怪的是，它可以打印第一个订购的商品，但不能打印以下商品……

尽管升级了依赖项，但我无法将此方法转换为 RxJava3

类型不匹配。必需：io.reactivex.rxjava3.disposables.Disposable？找到：io.reactivex.disposables.Disposable！

我应该如何准确地从 RxJava2 中清理项目？

我试过无效缓存/重启：什么也没发生。

我在我的项目中将 RxJava3 与 Room 一起使用，但出现以下错误

错误：不确定如何将游标转换为此方法的返回类型（io.reactivex.rxjava3.core.Flowable>）

下面是我收到错误的 DAO 接口方法

我想可能是因为我在成绩文件中使用了以下依赖项：

我试图找到 RxJava 3 的上述依赖项，但我找不到它。

我想知道如何将 RxJava 3 与 Room 一起使用，或者我应该在我的项目中使用 RxJava 2。

大多数Flowable.subscribe()重载都返回 a Disposable，这使得流能够被清理。我习惯这样做：

但是，使用时.subscribe(Subscriber)不会Disposable返回。我想使用.subscribe(Subscriber)，所以我可以传入 aTestSubscriber来验证行为。那么在这种情况下我将如何处理流程呢？

我在 Javadoc 中搜索了合适Subscriber的 s。有DisposableSubscriber哪个看起来可行，但有两个问题：

1. 类描述如下，这表明cancel()不能从流外部使用：

使用受保护的 request(long) 请求更多项目，并使用cancel() 从 onNext 实现中取消序列。

2. TestSubscriber 不扩展 DisposableSubscriber。

我有一些像这样Flowable组成的FlowableTransformer：

这里的基本用例是具有某种形式的分支逻辑- 如果元素是 A ( filter) 则执行 B ( map) 或者如果它们是 C 则执行 D。

但是，在下游，当我存储Disposableand 稍后调用cancel它时，取消只会在流中冒泡，直到Flowable返回mergeArray. 其上游，即呼叫上游的运营商compose(transformer())，从未收到取消。

所以我认为这本身就是一个问题Flowable.merge()（或者更确切地说：我缺乏理解），所以我改用 areplay()和 a ConnectableFlowable：

然而——同样的事情也会发生。cancellation只冒泡到ConnectableFlowable.

但是，我需要在整个 Flowable 上进行取消，以便项目的来源停止生产。

有没有办法做到这一点？或者我应该以不同的方式处理分支逻辑？

最近，我们的项目从 RxJava 2 迁移到了 RxJava 3。当我们在 Firebase 测试实验室中运行测试时，我们看到应用程序在测试期间崩溃：

RxJava 3 包含静态接口方法，如此处所示，但 Android Gradle 插件应该对这些用法进行去糖处理，并使它们在 Java 8 之前的 API 级别上工作。有谁知道这里发生了什么？