我有一个创建一个可观察对象的函数，它负责获取一些数据。此函数被多次调用，因此在后台有N个线程获取数据。一旦获取了数据，我就必须对它们进行串行处理。每一轮处理都应在收到通知并逐个处理所有数据时开始(我们不关心顺序，也不关心是否仍有X个后台线程在处理我们当前拥有的数据时仍在获取数据)。java.util.concurrent.Thr
浏览 84提问于2021-02-09得票数 1
回答已采纳
所以我按照下面的流程图使用了RxAndroid，Retrofit2和Room。这是一个相当复杂的异步操作，我正在努力解决它。我是Rxjava的新手，我花了几个小时阅读它，但它对我来说仍然非常抽象。在尝试从服务器获取数据之前，我需要登录到服务器并获取访问令牌，然后在收到响应后注销。因此，我需要以某种方式链接操作并使用前一个请求的结果，但我还需要能够处理链中的任何错误。我不确定如何处理RXjava中的链
浏览 0提问于2019-07-01得票数 0
1回答
我目前正在学习如何使用RxJava，我希望计算从数据库中获取的数据，然后异步地计算它们，但是等待所有这些数据都被计算出来。= getDatasFromDatabase();
list.forEach(data -> compute(data)); // How can I make this async using RxJava
浏览 5提问于2017-09-14得票数 0
回答已采纳
1回答
在这一点上，它比较了两个代码片段，一个使用Vert.x的未来，另一个使用Vert.x的RxJava API。代码基本上是从数据库中获取数据，并处理结果集以将行映射到对象。一旦你有了，我们就可以一个一个地处理每一行。幸运的是，Vert.x为这个开发模型的挑战提供了答案，并为您提供了一种使用反应性编程开发模型实现反应性微服务的方法。Vert.x提供了RxJava API，用于：.组合和协调异步任务.作为
浏览 0提问于2021-08-04得票数 1
回答已采纳
我在基于会话的应用程序使用卡尔图拉resftful APis工作。假设我有C1、C2、C3、C4、C5、C6片段和
每个C都有它自己的数据集(通过n/w调用，异步任务)加载数据会阻塞主线程，如果用户滑动到另一个页面，一个新的异步任务将被执行，而前一个
浏览 15提问于2016-09-27得票数 0
6回答
在搜索了安卓体系结构组件之后，我意识到 MVVM 在某些方面优于其他体系结构，所以我开始学习MVVM，我使用Kotlin语言，但问题是当我搜索教程开始学习时，我发现了很多组件，比如RxJava、RxAndroid、Dagger2、Room、Lifecycle等，但是他们没有说明为什么要使用MVVM，以及为什么要选择一些特定的组件。我将给你们举几个例子：
2-安卓MVVM与Dagger2，改装，RxAndroid
3-带有MVVM dagger2 RxJava<
浏览 4提问于2019-02-06得票数 14
回答已采纳
3回答
我一直在研究python中的线程、多进程异步等各种选项，以此作为处理两个传入流并将其合并的方法。我有一个通过套接字传入的数据流(目前使用UDP作为在我PC上本地运行的另一个应用程序，但如果该应用程序需要在单独的PC上运行，将来可能会考虑切换到TCP )，还有一个通过RS232适配器传入的串行流，我需要合并这两个流然后在另一个套接字上重新传输这个新的流。
问题是它们以不同的速率传入(串行数据以125 at传入，套接字数据以60-120
浏览 27提问于2020-11-19得票数 1
1回答
我需要从已分页的API中获取所有数据。我以前实现过类似的方法，当我有一个RecyclerView时，onScrolled()我会检查是否有更多的数据存在，然后获取下一个页面。现在，我没有任何RecyclerView，在第一个实例中，我需要递归地从API获取所有数据以进行处理。我应该使用RxJava吗？对RxJava不是很熟悉。目前，我使用Retrofit作为API。
浏览 5提问于2020-06-26得票数 0
Callback{ void onPreview(byte[] data); }如何用RxJava正确地处理这种情况？我想异步地从这个流中获取数据，尤其是当我完成工作时。
浏览 2提问于2016-09-20得票数 1
回答已采纳
3回答
TLDR :我在RxJava可观测到的环境中进行后台处理，我正在进行集成测试，我希望能够独立地等待处理完成，以确保从一个测试开始的后台处理不会干扰另一个测试。简化后，我有一个@RequestMapping方法，它执行以下操作：
这个异步处理
浏览 6提问于2016-04-29得票数 7
回答已采纳
1回答
我有一个需要由方法处理的任务列表，这个过程需要很长的时间，所以我希望列表中的任务以异步方式逐个处理，并以异步流的形式返回结果，这样下游处理就不需要等待整个任务列表的完成： AsyncStream<R>methodA(List<T> tasks){tasks.forEach(t -> {calculation that takes a long time})} 在互联网上进行了简短的搜索后，我发现RxJava可以处理异步流<
浏览 17提问于2020-12-26得票数 0
回答已采纳
或者换句话说，在应用程序结束后，甚至当应用程序从doWork()存在时，我应该如何安全地更新我的Room数据库。
浏览 0提问于2018-11-16得票数 0
在使用同步和异步调用时，我对Retrofit有很好的掌握。但是，我在创建一些复杂的任务时遇到了一个小问题，我必须：
我读到了这个问题，我意识到RxJava会解决我的问题。但坦白地说，到目前为止，我发现很难理解整个过程。如果我读了一些正确的示例，以
浏览 1提问于2015-06-01得票数 22
2回答
我在我的安卓项目中使用RxJava，我对此感到高兴。我目前正在使用它来使我的DAO方法异步化，并使UI侦听它们。但是我有一个大问题，就是当我使用Observable<List<User>> getLists()从数据库中检索一些数据时，我需要在我的ViewModels中使用List<User>，但是我不能从可观察到的地方提取它我在互联网上搜索，人们说不建议提取对象，但在这种情况下，我如何使用
浏览 0提问于2019-04-29得票数 0
回答已采纳
我的新闻有List<News>列表.我必须为每个新闻发出异步请求，以获取新闻图像列表(来自API)。我试着用RxJava做它，但我做不到(
我认为使用该Observable.fromIterable(newsList)，然后使用zipWith(imagesListRequestObservalbe,News, News(with images))，然后使用toList()，但是它是如何在代码中生成的--我不知道。请告诉我如何用RxJ
浏览 2提问于2017-06-21得票数 0
2回答
我们正在尝试用Paas环境将我们的遗留系统迁移到Microservice，我们有调度器作业一个接一个地触发并将消息放在MQ中，我们的Microservice中有MQ侦听器来获取消息、创建请求并向外部方发送请求这里出现了这样的问题:我们的微服务能够对外部服务进行异步调用，但是我们的外部服务无法处理异步调用，因此它返回错误的数据。例如，我们正在以每分钟40至60次的请求访问外部服务，而外部服务只能处理每分钟6次请求。
因此，如何使MQ侦听器缓慢处理。我尝试将setMaxCo
浏览 0提问于2019-07-13得票数 0
回答已采纳
我需要对数据进行异步的、可观察的查询，并且观察处理程序必须在后台线程上运行，因为我必须对结果进行一些代价高昂的后处理。对于Java来说，有两个如何与空间异步交互的选项:使用Rxjava或Guava/LiveData (参见)
如果我想要一个异步的、一次性的(而不是可观察的)查询并接受Guava/LiveData，那么API当然，我可以在主线程上使用onChange方法，在我的后台执行器上分配一个Runnable，<
浏览 6提问于2021-04-17得票数 0
回答已采纳
和RxJava，如何在数据列表上顺序执行异步方法？，只有在异步任务完成后才能运行callback。这意味着dataArray中的每个对象将被一个接一个地处理，而不是并行处理。现在，在RxJava中，我可以通过调用以下命令调用dataArray上的处理函数：
String[] dataArray = new String[] {"file1", "file2", "file3我问这个问题，因为我找不到关于
浏览 2提问于2017-03-14得票数 0
我使用kotlin来开发application.Now，我想从服务器上获取JSON数据。
在java中，我实现了异步任务以及用于从Url读取JSON的Rxjava。如何使用kotlin从Url读取JSON？
浏览 3提问于2017-07-03得票数 8
云服务器
ICP备案
云直播
对象存储
实时音视频
腾讯云开发者
