rx-android 相关问题

RX java io.reactivex.rxjava3.android.schedulers.AndroidSchedulers无法执行

实现'io.reactivex.rxjava3：rxandroid：3.0.0'实现'io.reactivex.rxjava3：rxjava：3.0.0'val TAG：String = RXKotlinDemoClass :: class.java.simpleName覆盖了onCreate（...

创建RX可观察对象而不调用onComplete是否有效？

我不是Rx方面的专家，如果这是一个小问题，抱歉。我正在执行轮询操作，必须等待更新，并且为此创建了Rx Observable；但是，我从不调用onComplete。但在...

单个可观察对象是否提供API来设置计时器和间隔？

我一直在使用RxJava的Single Observable进行网络任务。我已经看到Observable类型提供了用于设置计时器和间隔的API，如以下示例所示。 Observable.interval（0，2，...

如何将数组转换为可观察的

如以下代码所示，我想使用RxAndroid。但是我面临两个问题：1-我想将Array转换为Observable，但是无法识别方法.fromArray 2-为什么在...

通过纯RxJava实现防止快速点击

我正在尝试通过使用crunchLast阻止纯/纯RxJava的快速点击。下面的代码执行得很好，但是从未调用过blockSubscribe代码块。我想念什么吗？我不是...

RxJava Android：观察者不兼容类型错误

我想使用RxJava和RxAndroid进行以下异步网络调用。我在项目依赖项中包括了最新的RxJava（3.0.1）和RxAndroid（3.0.0），但仍然得到...

[在Android中使用MVVM架构时在哪里发出API的请求？

我正在我的应用程序中使用MVVM体系结构，我想从活动的viewmodel类发出API请求。这里的问题是我没有得到最好的方法。由于viewmodel已经存在...

为什么在RxAndroid中使用compose在io线程中运行而在主线程中运行？

我有这段代码，当我使用map进行转换时，您可以看到currentThread是背景线程，而我在主线程中使用compose（）时，它是后台线程。为什么这样工作，我...

重新订阅Android片段中的Observable

RxJava / Android的新手，想知道将订户放在Fragment中的什么位置？类似于以下代码的内容现在放在Fragment的onCreate中。当...

在多个片段中使用同一观察者，并且仅在可见片段中接收响应，而在后堆栈中不接收响应]]

我正在使用RxJava在我的android应用中访问该API。这里的问题是，如果在两个片段中使用相同的观察者，并且一个片段在堆栈中，另一个片段在顶部，则响应变为...

使用存储库模式在后台处理蓝牙流的最佳方法是什么？

我需要一个频率为1Hz的蓝牙连接处理程序，其使用方式类似于存储库模式，将数据保存在SQliteDB中，并在应用程序的多个视图上显示信息。我当前的选择是...

如何在RxJava2.0中处理可抛弃物>>

我是Rx世界的新手，我已经看到了多个如何处置Disposable的示例，但我不太了解其中的区别。我正在使用RxJava 2.0（v2.2.17）和RxAndroid（v2.1.1）。我的问题是...

java.lang.ClassCastException：com.google.gson.internal.LinkedTreeMap无法转换为ClassName

我用来通过改造和rxjava处理o的Api的两个响应的Api。我正在创建响应模型和错误模型。我不知道如何在一个Api中处理两个响应...

如何创建将听取哈希表更改的函数？

私有HashMap 项目=新的Hashmap <>（）;私有Flowable 您可以创建一个返回Flowable的包装器。然后，您应该覆盖put函数并使用该Flowable发出更改。

如何每秒观察一个方法的字符串返回值？

我需要观察一个字符串，该字符串是应用程序的顶级程序包名称，它是on更改的内容。我试图做这样的事情：getObservable（）.distinctUntilChanged（）...

如何观察方法字符串的返回值是每秒？

我需要观察一个字符串，它是应用程序顶级程序包名称，如果更改，请执行一些操作。我试图做这样的事情：getObservable（）.distinctUntilChanged（）...

我为什么不能向此Observable添加观察者？

以下是我的代码，我在本文中遵循：public static final String BASE_URL =“ https://newsapi.org/”;公共静态最终字符串ENDPOINT =“ / v2 / top-headlines”;公共...

RxJava-有点复杂的API请求，以及进度的详细信息

首先，我只使用RxJava / RxAndroid玩了几天。在psuedocode中，当我从Guild Wars 2 API加载数据时，我正在尝试完成以下操作：...

如何使用doOnNext，doOnSubscribe和doOnComplete？

RxJava2 / RxAndroid和Android开发的新手，但对Java非常熟悉。但是，在尝试“优化”并能够在一堆...

RXJAVA ROOM android

[尝试学习Room和RXJAVA。我大约有80％的理解，但是我被困在弄清楚其余的事情上。这是我在插入数据上遇到的错误。 java.lang.NullPointerException：...