2回答
我想知道过滤通过可观察管道的特定值序列的正确方法是什么。例如：我的第一个方法是：.filter(state -> state)state)
.subscribe(x -> doSomething
浏览 12提问于2020-02-17得票数 0
回答已采纳
1回答
我希望使用RxJava创建工作队列:我有一个线程在执行一些工作，并且我希望保证在完成/失败当前作业之前不会执行其他作业。我的解决方案只是阻止可观察到的，然后等待结果： return Observable.unsafeCreate { subscriber，因为所有东西都是同步的。对于这个特定的方法，这是正确的，但是：
我想避免“回调地狱”：有
浏览 4提问于2017-08-20得票数 0
我对.subscribeOn()在RxJava上的实际工作方式感到有点好奇。我有一段代码，它的工作原理是： .map().flatMap().doOnNext.subscribeOn(Schedulers.io())当这一行引起我的注意时，我正在阅读的文章，试图
浏览 0提问于2017-01-13得票数 0
3回答
我已经对此进行了研究，我知道RXJava正在使用可观察的模式，而Bolts则依赖于执行器。什么样的框架才能更好地处理需要在序列中完成的任务？我见过更多的人使用螺栓和rxjava，但我很想知道人们在这两者之间的经历。
谢谢!
浏览 3提问于2016-07-18得票数 7
回答已采纳
我所使用的API以“平面”格式返回对象(及其包含的对象)，而且我很难让它很好地用于Retrofit和RxJava。"id_to_age": { }使用Retrofit和RxJava，如何将其反序列化为带有name和age字段的Employee对象
理想情况下，我希望用onNext对象调用RxJava的Employee方法。这个是可能的<
浏览 2提问于2016-05-08得票数 2
回答已采纳
1回答
我目前正在将此功能从Java 8流转换为使用ReactiveX/RxJava。虽然它的工作，我不满意的结果，并正在寻求指导如何改进它！我的两个问题是：
1.每个源返回一个结果列表(List<List>)。由于转换需要在完整的数据集上执行，所以我需要将多个列表合并到一个单独的列表中。基本上，我需要一种将Observable<List<List<String&g
浏览 7提问于2017-06-20得票数 0
1回答
我很想知道RxJava框架是否像Lmax Disruptor一样是无锁、无等待的？它是否使用诸如高速缓存线填充之类的技术来避免错误共享以获得更好的性能？
浏览 0提问于2018-04-09得票数 1
1回答
我想要实现的是为房间数据库查询结果包装一个特定的类型abstract Single<User> find(String id);
是否有任何特定的适配器或方法可以帮助获得此包装？或者创建与android.arch.persistence
浏览 1提问于2018-05-17得票数 1
有没有一种方法可以将HystrixCommand转换为rxJava2的单个对象？这样做的主要目标是并行调用多个HystrixCommands，并等待它们全部完成(就像rxJava2的merge方法一样)。
提前感谢！
浏览 3提问于2018-02-22得票数 0
我试图从一系列API调用中构建一个可观察到的函数，但我无法让它正常工作。我有四个API名为ApiA、ApiB、ApiC和ApiD，它们使用RxJavaCallAdapterFactory返回可观测值。我正在使用zip接线员等待呼叫结束，我不确定这是一条路，但我对RxJava还很陌生，所以如果有其他更好的方法可以这样做，请告诉我。下面是我的代码，注释显示我被卡在哪里了 return O
浏览 4提问于2016-11-18得票数 6
回答已采纳
2回答
我最近使用了Rxjava，试图实现一系列事件(Api callas/Database操作)，在处理错误时似乎遇到了障碍。我能够将checkUser() -> FetchUserNotesRemote() -> SaveUserNotesLocal()序列与以下代码链接在一起我不知道如何处理
浏览 1提问于2018-04-04得票数 5
我是RxJava的新手，因此，问这个问题。我有一个输入流，我必须将其转换为特定大小的字节数组序列。类似于： .just(inputStream)这里的Chunk是一个自定义类，它包含从流中读取的字节数有没有人能帮我理解一下如何在RxJava中做到这一点？
浏览 0提问于2016-06-25得票数 8
1回答
我正在尝试用rxjava创建一个事件总线，在它上我会抛出一些命令，这些命令即使发生错误也会继续。我正在研究onErrorFlatMap，但是它已经不存在了，我还不能把我的头放在物化和非物质化上。这是我已经拥有的：public class EventBusTest {
我还希望我的服务
浏览 2提问于2015-04-22得票数 1
如果我执行这样的代码： stopWatch.start();我试过Schedulers.computation()和其他的，但它们还是一个
浏览 2提问于2021-01-27得票数 0
回答已采纳
考虑到Rx通常会使代码更短，我试着深入研究各种示例和如何工作的想法。这也可以在AsyncTaskLoader上完成，但是需要做的不仅仅是调用“取消”。对于AsyncTask，它还提供了进度的发布，这是我在Rx中找不到的另一件事。我试过的
-这实际上提供了一种处理AsyncTaskLoader的很酷的方法，因为它缓存了结果。，， --所有这些谈论的主要是<em
浏览 2提问于2017-10-23得票数 1
我有一个被初始化为网络调用的类变量。如何用RxJava实现这一点？另一种解决方案是，我可以简单地创建一个新的网络调用，以防止值仍未初始化，而不是等待，如下所示：
public Observable<String> getValue
浏览 5提问于2016-11-27得票数 8
回答已采纳
我有一个用Retrofit + RxJava进行的服务器调用，我想在屏幕上测试它的行为。Observable<AccountDetails> observable = Observable.just(details)
.delay(5, TimeUn
浏览 12提问于2016-07-26得票数 0
回答已采纳
我正在创建一个类似队列显示的应用程序。对于我的场景，队列数据总是在更新。除了使用Handler之外，是否有任何方法可以使我高效地调用API来获取最新数据。使用Handler可以解决我的问题，但这不是一个好的实践，因为每隔5秒继续调用API，可能会导致服务器超载/内存问题？顺便说一下，这个API是restful。
浏览 8提问于2021-11-18得票数 0
回答已采纳
2回答
游戏是向后工作的，所以玩家1等待玩家2的输入，反之亦然。我有一个使用框架运行API的API服务器。在我的客户身上我用的是Retrofit。因此，在客户机上，我希望每隔X秒轮询我的yes服务器(我知道这不是最好的方法)，检查是否有来自第2播放器的输入，如果是的话，更改UI (游戏板)。
我偶然发现了RxJava。我的问题是弄清楚我是否需要使用RxJava？如果是的话
浏览 0提问于2015-02-06得票数 7
云服务器
ICP备案
对象存储
云点播
实时音视频
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号