问题标签 [rx-kotlin]

我正在尝试移植 RxJava 库并利用 Kotlin 中的扩展功能。

是用 Java 编写的Transformers.collectWhile()，并具有以下签名：

但是，我遇到了映射collect参数的问题，而且我不擅长泛型。如何super用函数类型表达？

更新

我犯了愚蠢的错误。我不应该在深夜发帖。

我实际上是针对这个

这是我应该做的。

这是一个有趣的 RxJava 问题。

我想在输入每个字符时使用 RxJava 背压运算符快速查找输入的输入，就像 Google 在其搜索页面上所做的那样。我浏览了Backpressure文档并想出了这个（我正在使用 RxJavaFX/RxKotlinFX 来利用 JavaFX）。

这很好用。如果我对控件输入“Hello”，它将String在 200 毫秒无输入后发出“Hello”。但如果我想让它真正响应更快，我实际上应该为每个按键输入进行某种滚动累积。然后我的控制台输出应该看起来像这样：

当我输入“你好”这个词时，这些应该是我的全部排放，而 200 毫秒定义了在累积重置之前应该经过多长时间。我该怎么做呢？

我得到了Observable<Rates>，Rate 只是一个简单的对象：

我想把它Observable<Rates>改成Observable<HashMap<String,Long>.

因此，例如对于Rates(arrayOf(Rate("1"),Rate("2"), Rate("3"),Rate("3"), Rate("2"),Rate("2")))我期望结果的费率：

我开始创建类似的东西：

但我被困在这里，我不知道计算所有值？如果没有 5 of 4，我不知道如何添加空值 (0)。有没有办法使用 rx 来做到这一点？

我们试图观察 15 秒的间隔，或者每当我们向onNext我们的主题开火时refreshEventsSubject，但没有成功。

主题是这样发起的

private val refreshEventsSubject = PublishSubject<Long>()

然后我们试着像这样观察它

Observable.merge(Observable.interval(0, 15, TimeUnit.SECONDS), refreshEventsSubject) .subscribe { ... }

我们每 15 秒从间隔中获取事件，但主题在运行后没有触发

refreshEventsSubject.onNext(0)

任何想法表示赞赏。

（一切都是用 Kotlin 编写的）

我有一些问题。我是 RxJava/RxKotlin/RxAndroid 的初学者，不了解某些功能。例如：

然后我使用MainInteractor::convert Android studio 告诉我下一个

我尝试了很多变体并试图了解它想要什么，但没有成功。请帮助我...最好的问候。

RuntimeExceptions 应该表示编程错误，我希望我的应用程序在我的 observables 中的某些东西抛出 RuntimeException 时崩溃。

做这个的最好方式是什么？现在我正在考虑这个解决方案（它是 Kotlin，但我希望它是可以理解的）

但我对此表示怀疑。例如，使用此解决方案很难偶尔“捕获”特定的 RuntimeExceptions。也许有一种众所周知的方法来处理我只是不知道如何谷歌的情况？

我以为这就是它的工作原理，好像我错过了一些东西..

java.lang.AssertionError：项目数不匹配。提供：1 实际：0。

为什么我要使用 Kotlin 的协程？

似乎 RxKotlin 库的用途更加广泛。相比之下，Kotlin 的协程看起来没有那么强大，使用起来也更麻烦。

我的观点基于Andrey Breslav (JetBrains) 的这个设计演讲

演讲中的幻灯片可在此处访问。

编辑（感谢@hotkey）：

更好地了解协程的当前状态。

所以我有一个 300 毫秒的去抖动的 observable。
它在按键事件之后执行 API 调用。

有一个 API 锁可以防止将来的调用，直到它完成，但我还想检查 observable 是否正在运行（即进行 API 调用）并停止它。

这将如何实现？

我正在尝试用 Kotlin 编写一个 Android 应用程序。现在，我想在 ActionBar 中显示一个计数器。我为此添加了一个名为 show_timer 的项目。每一秒，它应该加一：

但不知何故，这不起作用。它将默认文本更新为 0，但之后它什么也不做。有人知道为什么这不起作用吗？

先感谢您，

尼克拉斯