新的Couchbase SDK使批量操作更容易使用，更多的性能使用rx。但是，对于单个值的操作，使用rx有什么价值吗？
浏览 1提问于2015-02-25得票数 2
回答已采纳
1回答
RxJava真实世界场景
、、、、
目前我正在学习如何使用RxJava。我完全理解反应性编程范例的概念，在这种情况下，程序需要对某些类型的更改(用户输入、Sensordata等)作出反应。许多教程，甚至是RxJava Github页面，都以一种非常简单的方式解释了RxJava，以创建一个可观察的和观察者。订阅观察者到可观察到的数据流，您将得到您自己手动创建的数据流。
浏览 9提问于2022-05-18得票数 0
2回答
编辑:我的答案如下 return new ResponseEntity(HttpStatus.OK);是否有办法使用RXJava (我正在研究的API使用RXJava，所以我希望遵循与其他模式相同的模式)？我对RXJava非常陌生，所
浏览 1提问于2017-12-19得票数 0
回答已采纳
我看到了一些项目，开发人员在Spring上将RxJava与Tomcat和Mysql结合使用。反应性流的主要优点是它只为每个多个请求创建一个线程，因此数据库连接也应该是非阻塞的。因此，我对tomcat和RxJava的好处特别感到困惑。基于Spring (Mysql)的Rest应用程序.
浏览 3提问于2021-10-26得票数 0
1回答
我有SplashScreenFragment，在这个片段中，我将使用Retrofit和RxJava从服务器加载数据，从服务器获取数据需要1秒到25秒。当我从服务器获得数据时，将调用onSuccess方法，在这个方法中，onSuccess方法将导航用户到HomeFragment第一个场景:当我打开应用程序时，将启动SplashScreenFragment并从服务器获取数据，假设从服务器获取数据需要1秒，在这种情况下，不能用onSuccess方法调用，应该等待7秒，然后必须调用onSuccess方法
浏览 4提问于2022-03-29得票数 0
回答已采纳
我是RxJAVA的初学者。我想给另一个线程分配一个初始化作业，并在它完成时通知我，这样我就可以开始工作了。因为这个可观察的没有任何数据要发出，所以我使用了中讨论过的Void。但是如果我使用Void，我的观察者的onNext和onComplete就不能工作了，我试着用字符串代替，而且它工作得很好。我想问一下，我是在这个场景中使用Void，还是RxJAVA有更好的方法来满足这种需求？, onComplete"); public void onE
浏览 2提问于2017-03-01得票数 0
回答已采纳
2回答
在处理RxJava状态更改(如方向变化)或异步平台事件(如推送通知事件)时，是否有一种处理订阅的优雅方法？到目前为止，我一直在使用EventBus来处理这样的事情，如果可能的话，我希望能够完全转移到RxJava (不需要EventBus)，但是在处理这些场景时，EventBus体系结构似乎要好得多(只需要注册和注销单独使用RxJava，我们似乎仍然需要一种方法来将订阅持久化到片段/活动生命周期之外(无论是使用加载程序--、Retained片段、Applicat
浏览 6提问于2017-02-12得票数 1
1回答
假设我有两个可观察的(A & B)，它们本质上是网络调用(使用Retrofit给出上下文)。
首先，这是RxJava的一个很好的用例吗？我知道如何单独执行每个场景(最后一个场景使用zip )，但我不知道如何同时完成所有这些<
浏览 1提问于2014-12-09得票数 3
回答已采纳
2回答
场景-为某些项目(假设4个项目)进行服务调用，这将更新数据库。顺序并不重要。所有的服务调用都是相互独立的，但是要等到所有的调用都完成了，所以我想使用rxjava1.x进行并行调用 dbClient.update(entry.getValue()); // how can I call this parallely using rxjava
浏览 1提问于2019-02-25得票数 0
对于以下场景，正确的RxJava运算符是什么：
我想检查是否存储了令牌，如果没有，则从网络获取令牌并使用它执行另一个网络请求。我认为应该使用and/then/when或filter和flatMap的组合来完成，但不确定如何完成。
浏览 0提问于2016-08-04得票数 1
我正在尝试使用rxJava、rxAndroid、Retrofit2和OkHTTP3从URL端点下载文件。尝试：* retrofit2.adapter.rxjava.RxJavaCallAdapterFactory * retrofit2.Retrofit.nextCallAdapter(Retrofit.javaServiceMethod$Builder.createCallAdapter(ServiceMethod.java:232) . 16
compile 'io.reactivex.<em
浏览 10提问于2017-02-05得票数 17
回答已采纳
4回答
房间支持RxJava 3
、、、
我在项目中使用带有文件室的RxJava3，但收到以下错误下面是我收到错误的DAO@Query("SELECT * FROM wishlist_table")我想这可能是因为我在成绩文件中使用了下面的依赖项：
implementation "android
浏览 5提问于2020-06-14得票数 6
2回答
我最近在我的项目中添加了 SDK；但不幸的是，我不能再使用RxJava了，它会导致重复的异常。值得一提的是，在将SDK添加到项目之前，一切都正常工作。rxjava-2.0.4.jar (io.hengam.lib:rxjava:2.0.4) and rxjava-2.2.9.jar (io.reactivex.rxjava2:rxjava:2.2.9modules rxjava-2.0.4.jar (io.hengam.lib:rxjava</
浏览 4提问于2020-03-24得票数 2
回答已采纳
2回答
我的场景非常类似于这个图像：应用程序的流程将如下所示：
创建一个observable1以从本地文件系统获取数据。
浏览 7提问于2016-03-23得票数 1
回答已采纳
在处理各种背压场景时，我实现了这样一种情况:一个订阅者使用缓冲区的速度很慢，而另一个订阅者则消耗掉扔给它的任何东西。使用Scala和Akka Streams。我通常尝试开发一个RxJava版本来进行比较，但我在这个版本上卡住了。在Akka Streams中，我可以构建一个图，其中一个源在2个通道上广播，并从这些通道消耗一个慢接收器和一个快速接收器。在RxJava中，有用于广播的share操作符，但是缓冲和节流逻辑不在Subscriber上，而是在Observable上。因此，我不确定如何应用缓冲和节流，而
浏览 1提问于2016-09-02得票数 2
码 @Override
public void onSubscribe(@io.reactivex.rxjava3MainActivity.activityMainBinding.activityMainLinea
浏览 16提问于2022-01-05得票数 1
回答已采纳
如何像在RxJava Observable.zip中那样合并两个API的结果？ 2)我使用声明式客户端来连接API。如何捕获此类场景中的异常？在Netflix Feign Client中，我们使用FallBack工厂。我如何在Micronauts中做同样的事情。
浏览 11提问于2020-05-02得票数 0
所以下面的场景:我有一个带有f.e.的动态数组列表。ids。我想对这个列表中的每个id做一个对api的请求。以下请求应仅在前一个请求获得成功应答时才会启动。所以没有任何要求。有没有什么很好的方法可以用retrofit和rxjava来接收这个？foo(++position, idList, controller);});有没有办法用rxjava2在pretty中做到这一点？我刚刚为rxjava2想出了一个异步解决方案：(对我来说这看起来不错，但并不能完全满足我的工作……
Observable.fromIterable(
浏览 2提问于2018-06-08得票数 1
=> { const request = await fetch("http://25.102.238.73/api/repos/RxJava
浏览 11提问于2021-01-22得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
