rx-java 相关问题

在简单情况下使用响应式编程的原因

请有人解释一下使用反应式的优点是什么： Observable 问候 = Observable.just(“你好”); Observable 大喊大叫=greeting.map(s -&g...

Jetpack Compose 可点击修饰符不起作用

我的屏幕上有一个使用 Jetpack Compose 实现的设置按钮。我希望当我单击按钮时，我的 ViewModel 应该更改主页的状态以显示设置弹出窗口。

收集 RxJava 中少数 PublicSubject 的所有响应

我的问题是： 我的代码中有这个方法： 公共 PublishSubject getUrl(String requestId) {...} 我有 5 个 url 可以从这个方法中获取，但我需要验证每个 url。如果这 5 个你...

2 也许在ROOM+RXJAVA中查询

我在ANDROID应用程序中使用ROOM + RXJAVA作为SQLITE数据库。 我有个问题。我需要插入一条新记录，但在此之前查询更多信息。 我使用 Maybe、Single 和 Completab...

为什么即使在 API 上共享数据，我的回收器视图中也没有任何内容？

我正在尝试使用 GET 方法从本地获取数据。这是服务代码。 这是API接口 接口API{ @GET("天气预报") 有趣的 getweather(): Single 我正在尝试使用 GET 方法从本地获取数据。这是服务代码。 这是API接口 interface API { @GET("WeatherForeCast") fun getweather(): Single<List<Data>> } 这是 API 的 APIService 类： class APIService { private val BASE_URL="http://localhost:5000/" private val api=Retrofit.Builder().baseUrl(BASE_URL) .addConverterFactory(GsonConverterFactory.create()) .addCallAdapterFactory(RxJava3CallAdapterFactory.create()) .build() .create(API::class.java) fun getData(): Single<List<Data>> { return api.getweather() } } 在这里查看模型： class APIViewModel: ViewModel() { val data = MutableLiveData<List<Data>>() val error = MutableLiveData<Boolean>() val loading= MutableLiveData<Boolean>() private val apiService=APIService() private val disposable=CompositeDisposable() fun refreshdata(){ getfrominternet() } private fun getfrominternet(){ loading.value=true disposable.add( apiService.getData().subscribeOn(Schedulers.newThread()) .observeOn(AndroidSchedulers.mainThread()) .subscribeWith(object :DisposableSingleObserver<List<Data>>(){ override fun onSuccess(t: List<Data>) { data.value=t error.value=false loading.value=false } override fun onError(e: Throwable) { error.value=true loading.value=true } }) ) } } 这是我制作所有内容的 ActivityMain.kt 文件。 class MainActivity : AppCompatActivity() { private lateinit var recyclerview: RecyclerView private lateinit var list: List<Data> private lateinit var binding: ActivityMainBinding private lateinit var adapter: RecyclerviewAdapter override fun onCreate(savedInstanceState: Bundle?) { super.onCreate(savedInstanceState) binding= ActivityMainBinding.inflate(layoutInflater) setContentView(binding.root) binding.recyclerview.setHasFixedSize(true) list= listOf() adapter=RecyclerviewAdapter(list) binding.recyclerview.adapter= adapter binding.recyclerview.layoutManager=LinearLayoutManager(this) } } 我期待在模拟器的屏幕上看到我共享的数据。但我什么也没看见。也没有任何bug。我可以做什么来解决这个问题？ list= listOf() adapter=RecyclerviewAdapter(list) 您在此处向适配器传递一个空列表。我建议将 viewModel 传递给适配器，然后观察 mutableLiveData，以便在它更新时将项目添加到适配器并通知它更改。

lateinit属性列表尚未初始化

我在项目中使用了retrofit、rxjava和recyclerview，立即出现问题。这是MainActivity.kt 文件： 私有 Lateinit var recyclerView: RecyclerView 私人迟到...

Springboot webflux/webclient 按顺序调用restApi获取列表

在网络客户端中，如何按顺序调用列表中的每个元素。例如，在下面的代码中，我有值列表，我想为列表的每个元素调用 apiA 或 B，但在序列中...

测试使用 Room 和 RxJava 实现的数据库时出现“java.lang.AssertionError：值不存在”

我对 RxJava 库、反应式编程和 Room 数据库非常陌生。所以我最近才了解到，在处理数据层之前必须先对其进行测试。所以我正在编写所有这些代码...

Java Spring WebFlux 与 RxJava

我开始学习 Java 响应式编程。整个反应范式对我来说是新的。 在我的学习过程中，我遇到过一些术语/库，例如 Spring WebFlux、projectreactor...

映射器函数返回空值

我为调试和发布设置了相同的构建类型， 构建类型{ 调试{ buildConfigField "String", "API_BASE_URL", "\"https://www.testUrl.com/api/\"" minifyEnabled true

在模块 jetified-kotlin-stdlib-1.8.10 中发现重复的类 kotlin.collections.jdk8.CollectionsJDK8Kt

我的项目是用Java编写的，但是当我尝试编译该项目时，它会抛出与kotlin相关的错误，即存在重复的类，而我并没有真正使用任何kotlin依赖项或kotlin，任何...

有人尝试过使用 rxKotlin 在 android 中进行长轮询吗？请帮助我

当我请求api时，服务器将在10秒后发送响应。 客户端收到响应后，我必须立即请求返回 api。 像这样。 有趣的 getSampleApi() {

如何将函数应用于 rx-java Flowable 的每个元素？

如何将函数应用于 Flowable 中的每个元素？我试图将一个函数应用于可流动发布者中的每个项目并收集结果，但该函数永远不会被调用。 完成标记...

如何同步列表中的可观察对象？

我想对列表中的每一项执行运算符。当上一项的运算符完成时，应触发列表的下一项。目前（见代码）操作员执行...

创建一个不会在完成或错误时终止的 RxJava 主题

我正在尝试创建一个可以订阅 Observable 的 RxJava 2 Subject，但当订阅的 Observable 由于错误或完成而终止时不会终止。 本质上，这...

我们有没有可能在 OkHttp 拦截器中停止请求？

在我们的应用程序中，我们遇到了一个特殊情况 - 如果我们的 App.specialFlag == true，我们需要停止来自我们代码的任何请求。我们认为，在这种情况下最好的方法是包含特殊的拦截器

每 30 秒调用任何方法的最佳方法是什么

我需要每 30 秒调用一个方法，最好的方法是 Handler、Observable.interval() 还是有其他有效的方法

使用 AtomicIntegers 构造的可观察对象在 RxJava 中的意外行为

这是测试用例： 导入 io.reactivex.rxjava3.core.*; 导入 java.util.concurrent.TimeUnit； 导入 java.util.concurrent.atomic.AtomicInteger； 公共课 MainTest { 公共静态 AtomicInte ...

androidx.lifecycle.LiveDataReactiveStreams 类在版本 2.6.0 之后找不到

我刚开始玩LiveData。 我按照官方 Android 文档导入了不同的工件。一切都很好，直到我需要将 Observable 转换为 LiveData。但是

doOnError 没有捕获异常

我刚刚开始使用 RxJava，但也许还没有点击。 1. 整数 [] 项目 = {1, 2, 3, 0, 0, 4, 5, 6, 1}; Observable.from(项目) .map(this::invert) .订阅...