问题标签 [rx-kotlin]

我在 kotlin 中使用 rxjava 2 但它没有编译我应该如何解决它？

我正在编写以下代码片段以从 firebase 数据库中获取已保存食物的列表，然后使用该列表，我再次从 firebase 数据库中获取个人食物详细信息。

以下代码工作正常，除了我无法弄清楚如何让第二个 flatMap 知道第一个 flatMap 的发射已经完成（所有食物列表都已处理）。所以我无法调用onCompleted()方法，因此无法检测到整个过程何时完成。

查看以下代码段中的评论：

谢谢。

我像这样初始化我的变量：-

但我不能这样做。IDE 抛出错误：-

这样做，IDE 说你永远不会为空：-

在发布已缓冲的元素列表之前，我有一个缓冲流，等待预定量的静默时间：

我想DEBOUNCE_TIME根据缓冲项目的平均值进行动态调整，但我很难弄清楚如何实现这一点。

我有一个自定义的 Android TextView，它通过 CountDownTimer 显示游戏中剩余的时间

如何设置在调用 countDownTimer 的 onFinish() 方法时发出值的 observable？我需要这个，以便在主要活动中，我可以订阅该 observable 并在倒数计时器到期时执行必要的操作。

为了提高我在 kotlin、Rx、Retrofit2 方面的技能，我决定做一个演示项目。演示项目包括在回收站视图中显示帖子，然后在详细活动中显示帖子的详细信息。
我在显示来自不同 api 调用的数据时遇到了困难：用户名、标题、帖子的正文和帖子的评论数。

我的问题是我想做多个请求，然后拥有所有需要的数据，以便在详细活动中显示它们。这意味着打电话给我用户名，然后打电话给我帖子的评论数量。帖子的标题和正文来自主要活动中完成的请求，我只是将它与捆绑包一起传输到详细活动。

Api 调用：
// 返回帖子 1 的评论
http://jsonplaceholder.typicode.com/comments?postId=1

// 返回用户2的信息
http://jsonplaceholder.typicode.com/users/2

// 调用用于在主要活动中显示帖子
http://jsonplaceholder.typicode.com/posts

我还是 Rx 的新手，我正在考虑使用 flatMap，但我不知道如何在 kotlin 中将它与 Flowable 一起使用。

我已将第二个调用放在方法getNumberComments中：

我注意到的其他想法是，有时流没有进入 onComplete，有时它在 onNext 上仍然被阻塞。不明白为什么？

任何帮助将不胜感激！非常感谢 ：）

我是 rxjava/rxkotlin/rxandroid 的初学者。

我需要按顺序处理三个不同的异步调用。问题是第一步返回 a Single<LocationResult>，第二步返回 a ，Completable第三步返回 a Completable。

（单个 -> 可完成 -> 可完成）

现在的问题是最后一个Completable取决于第一个的数据Single

我目前的解决方案：

我认为这是一个糟糕的解决方案，但我不知道如何正确地做到这一点。

这是正确的方法吗？

我应该如何处理Completeables？通常我应该什么时候处理Observables？

我正在尝试构建一个演示器，它在某个时间段内计算一些事件，仅在第一次加载时显示加载，并在完成后更新 ui。因为可以通过多种方式（例如用户首选项）更新事件，所以我需要能够告诉演示者事件已更新并且必须再次刷新它们。这是我现在所拥有的：

主题是PublishSubjectInt 的。我onNext()在订阅后就这样做了，因为我希望数据在订阅后立即刷新。

上面的代码在我的单元测试中创造了奇迹，而且只有当我在连接了调试器的设备上运行它时。如果我只是运行它（没有任何调试器），它会到达该view.showLoading()部分，但永远不会provider.calculateEventsBetween(TimePeriod.aYearFrom(firstDay)因此 UI 被加载“卡住”。

有任何想法吗？

我retorift用来点击getAricleapi 并获取与用户相关的文章列表。getArticle如果传递的令牌过期，api 将抛出错误，如果是这样，我必须调用refreshTokenapi 来获取新令牌，然后我必须再次调用getArticleapi

编辑

尽管给出的答案显示了一些方向，但这些并不是我问题的直接答案。这就是解决它的方法，但我觉得这可以重构为更好的代码

编辑

我将代码重构为更简洁的版本

编辑

请检查我对最终重构代码的回答

我有一些方法

并且想要检查本地项目，如果它是空的，那么例如从网络中获取该项目。

但是看到代码没有执行network.getBarcodeTemplates()这个函数。