1回答
我想在UI中显示两个值。这些值是从API服务器检索的，我正在使用Retrofit来获取它们。我想同时发送它们。 我该怎么做呢？
浏览 20提问于2019-02-28得票数 0
回答已采纳
1回答
我正在努力学习Rxjava，并且仍然处于一个非常基本的水平。我正在寻找一些关于以下问题的指导。我有这两个可以观察到的， return ConnectableObservable.interval如您所见，在getPlayheadPositionInMilliseconds中，订阅者将在每1000 As之后获得新值，现在我想将此值与从getContentDurationI
浏览 1提问于2019-07-31得票数 1
回答已采纳
1回答
基于资源稀缺性的背压观测
、、、、
在RxJava 1/ RxScala中，如何在以下情况下观察到节气门/背压源？它可以工作，但这是非常不优雅的，可以防止多个同时进行的请求： Observable.just
浏览 3提问于2016-11-09得票数 0
回答已采纳
我在我的项目中配置了一些基于Hybris (基于rxJava的实现)的服务(带有可观察的返回类型)。这些服务中有几个是从单个方法调用中调用的。当我检查日志时，发现它们是并行运行的。但是，当我使用rxJava创建了一个示例POC并创建了多个可观察对象时，我发现它们是同步运行的(一个接一个，除非显式配置为在新线程上运行)。这就是为什么我的问题是，Charon是否被配置为异步(当使用可观察的返回类型时)。
浏览 12提问于2019-06-11得票数 0
1回答
我在我的应用程序中同时使用这两种。Kotlin Coroutines用于单个交互，例如DB或API调用。同时，我还使用RxJava Flowable来观察传感器事件。Kotlin Coroutines有dispatches，RxJava有shedulers。它们的思想是提供最大效率的线程池，其大小取决于硬件配置。因此，如果同时使用这两个线程，例如，我可以有8个正在运行的线程，4个在Dispatchers.Default中，4个在She
浏览 1提问于2018-11-15得票数 1
回答已采纳
我正在寻找一种方法，希望使用RxJava实现一致性，以监视可能在不同时间触发的多个订阅者的进度。例如，如果我有两个长期运行的任务附加到按钮按下。我按下按钮1并启动可观察/订阅者，在运行中途我按下按钮2以启动第二个可观察/订阅者。
我希望在没有任务运行时启用按钮，在一个或多个任务运行时禁用按钮。
浏览 1提问于2016-02-04得票数 3
回答已采纳
在splash中，我连接到Api并创建了一个会话，现在我有多个网络调用(所有这些都必须在异步任务中完成)。建议：
管理每个片段的网络调用的最佳方法是什么:我是否应该在8-10左右为这些异步任务创建线程池，并在splash中启动线程池。
浏览 15提问于2016-09-27得票数 0
2回答
TL；DR -在默认情况下，在观察可观测事件时只使用一个线程吗？AtomicInteger counter = new AtomicInteger();
testSubject.onNext(i);无论我如何更改这个示例--除非我使用.toFlowable(.).parallel(
浏览 1提问于2019-07-23得票数 2
回答已采纳
5回答
我正在尝试使用Python生成器来再现反应性扩展“共享”的可观察概念。我可以这样使用： for elem in the_infinite_stream():我可以多次使用这个生成器，如：有办法在多个客户端之间“共享”生成器吗？似乎会这样做，但我必须事先知道我想要多少独立的生成器。其思想是，在其他语言(Java、Swift)中，使用反应性扩展(RxJava、RxSwift)的“共享”流，我可以方便地在客户端复制流。我想知
浏览 1提问于2019-04-14得票数 19
回答已采纳
如何在RxJava中创建一个从不同位置完成的对象(未来)，但我希望将一个可观察对象返回给某个客户端？第二个问题:如何在该可观察对象上获得多个订阅者？目前，我看到只有一个订阅者可以工作。
浏览 0提问于2016-07-08得票数 3
3回答
我正在编写一个应用程序，它接收JNI对Java类中静态方法的调用。receive(int value) { }我想听这样的事件，这是我所观察到的物体的一部分
浏览 8提问于2015-11-25得票数 1
回答已采纳
1回答
我已经开始学习RxJava和RxAndroid了。我想用RxJava替换我的观察者模式。观察者模式类似于具有注册和注销方法的安卓LocationManager类。"observable“类(不是指rx.Observable)在它自己的线程(HandlerThread)中工作，并拥有侦听器及其处理程序对象的映射，每个侦听器在其线程中被调用(通过处理程序)。因此，问题是如何使用RxJava实现它？这有意义吗？我读过关于PublishSubject和Subscriber的文章，但我不
浏览 3提问于2016-11-02得票数 0
我使用的是API 2和改进的RxJava库，我想执行700多个查询，每个查询都是一个改进的API调用。
如何在RXJava 2中使用zip运算符实现这一点？
浏览 0提问于2018-04-18得票数 0
我正在寻找一种优雅的方式来同时运行两个可观察对象，等待这两个对象完成(它们都从web上获取数据)，并且只在两个对象都完成后执行函数。
我还需要获取两个线程之间的时间差吗？在RXJava中有没有一种优雅的方式来做到这一点，特别是在android上。或者我必须在两个observable的oncomplete方法中设置一个全局计时器变量，然后才对它们进行比较？我的想法是将可观察值合并为一个，但我不确定如何获得时间差？
浏览 9提问于2017-03-06得票数 0
回答已采纳
我不清楚如何在RXJava中实现任务取消。
最终未来的取消将导致其依赖项的取消，例如，在序列中，3的3取消被传播到2，等等。RxJava wiki
浏览 4提问于2014-08-16得票数 14
回答已采纳
我有多个热的可观察物，它们可能会也可能不会发射粒子。因此，我希望合并这些可观察对象，如果它们中的任何一个发出结果，则处理结果，但如果其他可观察对象发出一个结果，则应将它们一起处理。应该发出：(2, null)(3, "Test")最接近我所需要的，但它只在所有可观察对象至少发出一项时才会产生结果
浏览 8提问于2018-01-11得票数 0
回答已采纳
1回答
我刚开始接触RxJava和Retrofit。假设我有Retrofit服务，它将Observable返回为如何在多个地方订阅此可观察对象我想在多个android活动中订阅它。
例如:假设我有一个登录页和登录页活动。登录页面出现在登录页面之后。当我在登录页面上提出网络请求时，结果应该在登录页面和登录页面上都能看到。
浏览 1提问于2016-06-14得票数 0
我试图从特定设备上的Device Information服务中获取所有特性。onConnectionSuccess(it, v) },问题是当我试图同时读取多个特征时我尝试使用来自的示例文档、关于SO的多个问题以及RxJava可观察到的文档，但我不知道自己做错了什么。Type mismatch.)
浏览 2提问于2020-05-30得票数 0
回答已采纳
1回答
在我的应用程序运行之前，我必须做一些配置，例如安装一个异常处理程序。因为我的应用程序有多个入口点(一个Activity，一个SyncAdapter)，所以我只想在我的Application类中做一次这个配置，并在入口点(Activity，SyncAdapter)上观察它这是Observable类中的Application (RxJava 2)：
ConnectableObservable<Boolean> observable = Obse
浏览 3提问于2016-10-27得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
