问题标签 [rx-kotlin]

问问题

For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.

223 问题
Newest
Active
Bountied
318
Unanswered
0 投票
2 回答
1871 浏览

kotlin - 带有 RxKotlinFX 堆栈的 Kotlin 给出无法访问类错误

当我在我的 pom 文件中使用以下依赖项时：

并运行以下代码：

我收到以下错误：

为什么我会收到此错误，我需要什么依赖项设置才能使用此堆栈？

0 投票
1 回答
512 浏览

android - RxKotlin - 动态观察者数组

我将 RxKotlin 与 Retrofit 2 一起使用

我正在尝试弄清楚如何在单个操作中拥有动态的观察者列表。

第一个观察者应该触发操作，所有其他观察者应该等到操作完成/失败

操作完成后，我需要进行数据操作（存储在缓存/内存中），然后通知所有观察者。

这是我所做的：

这是 Retrofit observable 创建（这个是在 Java 中的..）

我确信有更好的方法来做到这一点

谢谢！

0 投票
1 回答
339 浏览

kotlin - RxJava/RxKotlin 根据子类型拆分流

我有一个流ResponseMessage可以是不同的子类型。我想将流拆分为流，我可以在其自己的流中处理每种类型。

我的第一次尝试导致了我看不到的结果。

我现在的问题是：将流划分为一种特定子类型的流的惯用方法是什么？

0 投票
1 回答
447 浏览

rx-java - 仅当一个主题发生变化并从另一个主题中获取最新信息时才合并两个主题

我坚持让以下示例按预期工作，我尝试使用zipand combineLatest，如下所示，withLatestFrom但是它们都没有给出预期的输出。

我想要打印以下内容：

2 - 1

2 - 2

333 - 444

0 投票
2 回答
10578 浏览

rx-java - 链 Completable 成 Observable 流

假设你想在你的 Observable 链中插入一个 Completable，比如对于每个发射的元素，都有一个 Completable 运行并阻塞直到它完成，你会选择什么选项？（这里Completable.complete()只是举个例子）

  1. .flatMap { Completable.complete().andThen(Observable.just(it)) }

  2. .doOnNext { Completable.complete().blockingAwait() }

  3. 别的东西？

0 投票
1 回答
857 浏览

kotlin - 必需的 and found ? 
class TaskRepo(taskData: TaskData) {

companion object {
    private val repoByTask: LRUMap<String, OrderFormRepo> = LRUMap(2, 10);

     fun getInstance(taskData: TaskData): OrderFormRepo {






}



in getInstance method of companion object I am getting compile time error:
Required TaskRepo and found TaskRepo?







Spyder doesn't detect changes in imported python files


I'm using Spyder 3.2.4 (Python 3.6). Spyder doesn't detect changes in imported python files. For example:



test2.py:




test1.py:




When I wrote those classes, and saved them (in the same working directory), and ran test1.py the output was 5.



BUT when I change the function in test2.py, to like:




Save it, and then run python1.py, I still get 5. Only when I save, exit the IDE, and return, I will get the changed code (10). 



This behavior is going on since I started using Spyder (few months by now), and it's super annoying. Help would be appreciated.
0 投票
1 回答
82 浏览

kotlin - 我无法从 rxkotlin 中的 groupby 获取地图

你能帮我解决这个rxkotlin groupby 不工作吗？在 rxjava 中工作，但不是在 kotlin 中工作。非常感谢您的帮助

0 投票
2 回答
3614 浏览

android - 如何在android中使用数据绑定实现Switch

这是我的 xml：

这是我的视图模型

我想应用数据绑定，switch以便当我打开时switch应该 textView显示通知关闭并且检查值应该设置为 true，当我关闭时它textview应该显示通知关闭并且检查布尔变量应该设置为 false。请建议我如何使用 Data-binding 实现。

0 投票
1 回答
62 浏览

android - 当stream2基于stream1时，如何避免.zip（stream1，stream2，BiFun）订阅stream1两次？

我在 android 中使用带有一些复杂数据的 firebase。我需要保存参考资料，但我的 zip 操作或我处理 RX 的整体方式遇到了问题。

我想创建一个新A object的信息B，并更新我B object的信息以获取有关创建的信息A。当 firebase 操作都成功后，我将返回Single<A>

通过 logcat 时，我可以看到它SingleA被订阅了两次，并且两次推送到 firebase。我想避免这种情况！

那么，当 B 依赖于 A 时，如何在 A 和 B 上使用 zip 函数？并且没有 A 被执行两次？

0 投票
1 回答
759 浏览

android - 如何显示进度对话框并在项目单击时关闭

这是我的代码，我想dialog在项目点击上显示进度，它应该在那个时候关闭，直到 getQrImageBitmapshowDetail 功能完成，但我没有工作，请建议我如何实现这一点，如何在项目点击上显示和隐藏细节。谢谢！


12345678910