这是我的ApiService界面：Observable<List<Diagnostico>> getDiagnosticos(@Query("nombre")String patron); RxJava2CallAdapterFactory rxAdapter = RxJava2CallAdapterFactory.create(：
public List
浏览 6提问于2017-07-27得票数 0
我使用RxJava2 (单)对网络请求进行修改，当接收到响应时，添加对象包含的其他字段，有一个对象列表，我试图实现的是筛选出包含特定“id”的对象(在列表中)，当然，我希望它发生在后台线程上，然后在对象的列表过滤后发出响应超出作用域是否有一种方法可以在每个操作符中检测到它使用哪个线程？
浏览 4提问于2020-05-01得票数 0
1回答
我使用的是RxJava可观测值(数据库使用SqlBrite，远程服务器使用Retrofit )。我的查询代码如下： .createQuery(MyObject.TABLE_NAME,MyObject.SELECT_TYPE_A)
浏览 1提问于2016-10-22得票数 0
回答已采纳
5回答
我想要一个返回list的线程。我不能使用run方法，因为它的返回类型是void。我在一个类中的一个单独的私有方法中使用线程，在这个类下也有线程的调用者方法。调用者需要线程结果中的列表来执行一些操作。这是我的帖子。请帮助我理解如何从这个线程<
浏览 0提问于2013-10-08得票数 1
我想使用Retrofit2库进行API调用，返回可观察的泛型类型。
我收到一个错误: android.os.NetworkOnMainThreadException，正在打电话。
浏览 1提问于2017-11-14得票数 4
回答已采纳
3回答
我使用的是RxAndroid 2.0.1和RxJava 2.0.6。
我有两个可观察到的:一个基于某个字符串(ID)返回Maybe<MyObject>。当返回可选对象时，我必须调用接受MyObject实例的第二个对象，如果对象满足某些条件，则返回Single<Boolean>。然后，我可以对对象实例做一些进一步的操作。我的
浏览 9提问于2017-03-22得票数 5
回答已采纳
2回答
FixedThreadPool只运行您定义的多个并行任务。新任务只在旧任务完成后才开始。
如果不检查可调用性是否被中断(因为invokeAny找到了结果)，那么所有可调用的将一直运行到它们完成为止。A，但它并不总是返回MyObject对象，该对象是由someFunction()创建的，输入值最低的是finalI。因为executorService按照它们在callableList中的</em
浏览 11提问于2021-01-10得票数 1
回答已采纳
我是RxJava新手，我选择使用它，因为我认为它非常适合我的用例。private BehaviorSubject<Integer> rotatio
浏览 0提问于2019-01-06得票数 4
回答已采纳
我是kotlin的新手，我正在尝试在MVVM体系结构中使用Rxjava和实时数据的改进。我配置修改，并在ViewModel中使用可观察和订阅来使可观察的变量用于活动绑定布局。我的视图中有一个按钮，当我单击它时，request方法将开始并订阅它自己的数据的日志。但是我的变量在一开始和几秒钟后获得null，当更新完成它的任务时，我的变量会获得数据，但是日志值<
浏览 2提问于2020-05-24得票数 0
我的存储库类中有一个LiveData，它在一个活动(当然是通过一个视图模型)中被观察到(我使用的是MVVM体系结构)，当单击按钮时，调用一个API，它返回一个RxJava2 Observable (而不是Call)，因为我需要RxJava2将两个api调用压缩到一起。然后，应该将来自API的请求数据设置为LiveData的新<e
浏览 2提问于2021-08-07得票数 1
我在基于会话的应用程序使用卡尔图拉resftful APis工作。假设我有C1、C2、C3、C4、C5、C6片段和
每个C都有它自己的数据集(通过n/w调用，异步任务)加载数据会阻塞主线程，如果用
浏览 15提问于2016-09-27得票数 0
3回答
对于LiveData，RxJava中是否有类似于blockingNext或blockingSingle的东西可以同步获取值？如果没有，我怎样才能达到同样的行为呢？
浏览 1提问于2018-04-27得票数 10
回答已采纳
查看RxJava来构建对API的异步支持。现在，我们使用jetty +JAX @Path注释，并且不确定将传入的REST调用绑定到RxJava api的正确方法是什么。基本上，这是在释放请求线程的上下文中，直到DB的响应准备就绪为止。寻找关于上述的建议。
浏览 1提问于2014-03-31得票数 2
();Disposable disposable = naturalNumbers.subscribe(i -> log("Received "+i));
这里我们有两个重要的lambda第一个是传递给Observable.create的，第二个是传递给Observable.subscribe()的回调。在最初的lambda中，我们创建一个新线程，然后在该线程上发出值。在第二个lambda中，我们有接收在第一个lamb
浏览 0提问于2021-01-03得票数 0
回答已采纳
对于Java来说，有两个如何与空间异步交互的选项:使用Rxjava或Guava/LiveData (参见)
如果我想要一个异步的、一次性的(而不是可观察的)查询并接受Guava/LiveData，那么API将返回一个ListenableFuture (参见)。一个异步的、可观察的查询与Guava/LiveData相结合，返回一个Liv
浏览 6提问于2021-04-17得票数 0
回答已采纳
我想使用Hystrix (1.5.12)折叠，在Vert.X (3.3.3)中运行RxJava (1.3.3)。我遇到的问题是没有为请求缓存键的线程设置Hystrix请求上下文。创建HystrixObservableCollapser实现并在创建的折叠程序上调用toObservable()的类在某些Vert.X事件循环线程上被调用。上面返回的可观察到的</
浏览 1提问于2018-02-18得票数 3
3回答
嗨，我正在努力学习rxjava2。我试图使用rxjava2调用API，并使用改进来构建URL并将JSON转换为Moshi。 retrofit.create(RestApi::class.java).login(email, password)我从doServerLoginApiCa
浏览 3提问于2017-10-23得票数 0
回答已采纳
我有一个多线程C++应用程序，它可以从任何线程调用一个函数，如下所示，以便从列表/向量中获取一个对象。obj) return;注意:这里的范围是通过引用、值或指针来理解与函数返回相关的一些最佳实践，所以请原谅一些伪代码或缺少的声明(我使用锁/解锁，GlobalClass这里的问题是，如果在这个索引处的MyObject</em
浏览 0提问于2019-01-17得票数 1
回答已采纳
} }
抛出一个android.os.NetworkOnMainThreadException.我的问题是，如果我试图将这个函数放入线程中，那么我就无法返回用于其他函数的值。解决这个问题的最好方法是什么？
浏览 5提问于2019-12-29得票数 1
回答已采纳
我使用Spring和@RestController与Java 8一起实现REST，其中一个控制器方法需要调用另一个第三方REST服务。该方法概述如下(数据格式为JSON)：
浏览 7提问于2016-11-18得票数 0
回答已采纳
云服务器
对象存储
ICP备案
云点播
实时音视频
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号