问题标签 [rx-kotlin]

我正在使用带有 Room 和 Retrofit 的 RxJava/Kotlin。我确定我刚开始学习 RxJava 时不会写东西。场景是我调用检查数据库中是否有最喜欢的记录并将它们获取到列表中，从 API 获取数据并将其插入数据库中，使用以前的收藏夹列表更新数据库并获取所有记录，现在更新，列表。我在我的片段中得到了结果，但每次我得到它时，就好像我少了 1 个最喜欢的项目，直到我没有最喜欢的项目。

Repository

而在我的viewmodel

我实际上会在我的片段中得到这个列表，但是，正如我所说，它总是会少一个，直到没有。

addAll方法可用于合并可为空的可变列表，但是在这里它会引发编译时错误。

例子：

类型接口失败，请尝试明确指定类型参数。

在这里，我可以以任何方式合并这两个数组，在此先感谢。

我正在围绕 FirebaseFirestore 快照侦听器编写一个包装器，它使用 RxKotlin Observable 发出更改。

我编写了以下类，它使用 create() 方法创建可观察对象并在新数据快照可用时异步发出更改。

问题是我每次创建这个类的实例并且我停止使用它时都会泄漏内存。在不泄漏内存的情况下重写此类的最佳方法是什么？

任何有关如何创建可以从侦听器发出对象的 Observable 的资源都会非常有帮助！

执行具有可观察值并发出值的任务

// 这也是另一个带有重试的 observable。我想重试 2 次，但前提是执行任务成功。

只需要说明实现这一点

我的 observables 是这样定义的

initialLoading开始在 Activity 的onCreate方法处运行。click在按钮单击时执行。我有两个案例，第一个有效，第二个无效。

情况1

活动开始并在几秒钟后 单击按钮。WAIT_TIME输出：

案例2

活动开始并在期间结束之前 单击按钮。WAIT_TIME输出

所以，问题是点击事件丢失了。我希望点击事件等待加载，然后继续工作。简而言之，案例 2 的输出应该与案例 1 相同。

我如何使用 rx 运算符来细香葱这个。我试过merge了，但它只是结合了两者，点击事件不等待加载。

我也尝试过reply, cache, publish, share，但无法让它们的正确组合按我的意愿工作。

我是 Spring 5 和响应式编程的新手。我的问题是通过 REST API 为数据库创建导出功能。用户点击 GET 请求 -> 服务器读取数据并将数据作为 zip 文件返回。因为 zip 文件很大，所以我需要流式传输这些数据。我的代码如下：

我使用 curl 如下：

但它总是返回 406 Not Acceptable。有人帮忙吗？

太感谢了

我正在用 Kotlin 编写一个方法：

该行.flatMapObservable(Observable::fromIterable)导致错误：

这永远不会完成：

这确实完成了：

根据杰克沃顿的说法：

“你想要andThen(Completable.complete())。注意使用括号而不是花括号。后者创建一个不调用其发射器的 lambda。”

参考：https ://github.com/ReactiveX/RxJava/issues/5551

谁能更详细地解释这一点？我以为我理解 lambda，但这真的让我很震惊。

目前我正在使用 RxKotlin 在 Kotlin 中构建一个项目。我在 Rx 方面的背景主要是基于 RxJS。

我经常用于hot observables在 Typescript 中创建的模式看起来类似于以下内容：

这将允许我公开Observable，而不公开 theSubject和随后的subject.next();方法。

我的问题是：在 RxKotlin 或 RxJava 中建立类似逻辑的最惯用的方法是什么？