我偶然发现了适用于安卓系统的RxJava，它是一个很好的库。我是一个初学者，我知道它是如何工作的，但我在将我的旧代码转换为RxJava风格的编程时遇到了一些问题。public ArrayList<AppModel> getMyAppList(PackageManager pm, List<ApplicationInfo> list){ tem
浏览 11提问于2018-01-15得票数 3
回答已采纳
如何将未来返回的空白转换为可流动或可观察的RxJava？
我使用的是RxJava和AndroidX WorkManager，后者提供了返回Future<void>的API。据我所知，RxJava不处理空值，因此将立即执行NullPointerException。动机：--我想把这个未来变成一个Rx可观察/可流动的，这样我就可以在这个未来完成之后进行处理。我需要在最后返回一个Si
浏览 3提问于2020-12-18得票数 3
回答已采纳
我正在尝试将rxjava迁移到rxjava2。我可以使用下面这行代码将它转换为Observable<List<Task>>。Observable.from(mCachedTasks.values()).toList()
但是，我不能在rxjava2上转换它。1-我尝试了以下代码。返回Observable.fromIterable(mCachedTasks.values())，但返回Observable&l
浏览 0提问于2017-04-05得票数 0
我正试图逐步将安卓代码库从RxJava2转换为Kotlin协同服务。我们使用的是UseCases和Repositories。我已经将返回Observable的存储库方法之一转换为suspend函数。为了继续使用这个UseCase函数，我将suspend函数转换为一个使用kotlinx-coroutines-rx2的observable，该kotlinx-coroutines-rx2提供了rxjava
浏览 2提问于2022-02-17得票数 0
回答已采纳
假设我们有两个LiveData对象：LiveData<List<Bar>> barList;barList = Transformations.map(fooList, fooList1 -> {
List&
浏览 3提问于2017-09-04得票数 3
回答已采纳
建议：，但想知道做上述问题的更好的方法/架构。
浏览 15提问于2016-09-27得票数 0
1回答
我想在RXJava中将以下同步代码建模为异步代码。executeAsync(actions);}
我想在RXJava2中做同样的模型。任何帮助都是非常感谢的。
浏览 0提问于2018-09-19得票数 8
RxJava2CallAdapterFactory.create()的作用是什么？Retrofit retrofit = new Retrofit.Builder().addCallAdapterFactory(RxJava2CallAdapterFactory.create
浏览 1提问于2017-08-24得票数 5
我使用vertX和RxJava开始了一个项目，但我有一个问题，我找不到解决方案。我想对这个可观察对象进行一个操作，将其转换为一个发出包含每个消息的所有帧的ByteBufferd的可观察对象。我尝试了buffer方法，但它似乎被设计为根据任意标准(时间或其他可观察值)对项目进行重新分组。另一种方式似乎是使用compose订阅WebSocketFrame可观察值，在非结束帧上添加缓冲区，并在结束帧上“馈送”ByteBuffer可观
浏览 6提问于2016-07-11得票数 2
回答已采纳
0回答
我一直在尝试理解RxJava 2以及如何使用它。我还试图通过将我的代码转换为RxJava代码来理解RxJava。但我似乎还是不能理解它。如果有人能进一步解释如何重新编码，我会很有帮助的。} catch (Exception e) { } }
User user = new User();
浏览 10提问于2017-01-06得票数 0
回答已采纳
2回答
或ArrayList。@ColumnInfo(name = "email") var email: String) val listType = object : TypeToken<ArrayList<String>>() {
return.allowMainThreadQueries()
浏览 2提问于2019-07-01得票数 2
回答已采纳
2回答
例如：.filter(string -> string.getNumber() >5)是否有任何方法可以等待可观察到的结果并返回到函数中
浏览 4提问于2015-09-29得票数 8
回答已采纳
我目前正在将RXJava与数据库事务结合使用。这些数据库事务并不是线程安全的，因此必须在单个线程的范围内执行所有操作。或者，可以使用调度程序来：
将
浏览 2提问于2016-01-11得票数 2
2回答
我正在考虑将我的(Android)应用程序中的一些逻辑转换为使用RxJava，但是我很难找到一种方法来实现更高级的逻辑。这些源也分别用于应用程序的其他部分；我已经将它们转换为可观察到的。这使得事情变得容易得多，例如，如果数据库发生变化，更改就会被可观察到的用户简单地推送到UI中。因此，我的问题是，我如何(优雅地)将</e
浏览 8提问于2017-10-20得票数 1
回答已采纳
我是反应式编程(RxJava和RxAndroid)的新手。我想使用RxView.clicks()而不是单击侦听器。我把一个按钮放到main层，然后在onCreate方法的Main activity中使用Button，我写下了这个语句：ButterKnife.bind(this);RxView.clicks(btn_range)
浏览 6提问于2018-01-16得票数 1
回答已采纳
1回答
在RxJava (或一般情况下的RX )中，是否有任何方法可以将可观测数据组合成一种方式，直到所有可观察到的数据以任何一种方式完成为止(当它们中的任何一个抛出错误时都不会惊慌)，然后用一个单独的结果完成，其中包含关于哪个可观察到的结果成功完成以及哪个遇到了错误的信息？如果成功完成，它还会返回可观察到的结果，或者在失败完成时返回错误原因(如Throwable实例)？其行为将类似于此(RSVP.js)：
我可以选择实现一个类似于Scala的Try的概念，将这些可观
浏览 0提问于2015-07-17得票数 1
回答已采纳
1回答
重新编辑:我将使用该方法的结果来初始化某些按钮的可见性，在我看来，接受的答案在理论上似乎不错，但是第一个方法的返回值是Flowable>，而不是可流动的。因此，我不能将它作为参数传递给订阅，因为它需要可流动的，但它是Flowable>。我使用RxJava来观察我需要从SDK调用的方法。Schedulers.io())
.observeOn(AndroidSchedulers.mainThre
浏览 0提问于2018-10-31得票数 2
回答已采纳
谁能用清晰的例子解释一下RxJava中可观察、可完成和单一之间的区别？
在哪种情况下，我们使用一个而不是其他的？
浏览 2提问于2017-03-13得票数 132
回答已采纳
我是kotlin的新手，我正在尝试在MVVM体系结构中使用Rxjava和实时数据的改进。我配置修改，并在ViewModel中使用可观察和订阅来使可观察的变量用于活动绑定布局。我的视图中有一个按钮，当我单击它时，request方法将开始并订阅它自己的数据的日志。但是我的变量在一开始和几秒钟后获得null，当更新完成它的任务时，我的变量会获得数据，但是日志值不会更新。create(IRetrofitMethods::class.java)
private fun <T> ca
浏览 2提问于2020-05-24得票数 0
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储
腾讯云开发者
