rx-java

0热度

1回答

我试图证明RxJava与顺序（我认为是）阻塞计算相比的性能。我在看this post和this SO question。根据经验，使用System.currentTimeMillis（）和Thread.sleep（）进行基准测试在处理计算而不是I/O时不会产生一致的结果，因此我尝试设置简单的JMH基准测试。我的基准计算两个整数，并增加了起来： public class MyBenchmark

0热度

1回答

Rxjava翻新为用户解析api错误

我在库项目中使用RxJava进行翻新。一切工作正常，当我请求数据时，我会得到预期的结果。 @GET(Routes.ME) fun getUserObservable(): Observable<User> 从API类： fun getUser(): Observable<User> { return usersService.getUserObservable() } 从中使

1热度

2回答

RxJava轮询+手动刷新

我有一个列表要刷新每分钟。例如，用户列表在这里：https://github.com/android10/Android-CleanArchitecture/blob/master/domain/src/main/java/com/fernandocejas/android10/sample/domain/interactor/GetUserList.java 我添加使用repeatWhen定期

0热度

1回答

如何继续收听组合列表中2个可变更列表的更改？

我有两个Flowable列表我需要将它们合并，应用一些函数并获得Flowable列表最初的Flowable列表表示来自DB 的数据，并且想法是当在DB中可以改变时可以改变组合列表以及投入都改变了。我想拉链不是正确的方法，因为它一旦工作完成它的工作，并不会继续发出变化。我的问题，这可能是拉链的替代，我可以结合2所列出，适用于一些功能，并继续听取更新 Flowable.zip(shopping

0热度

2回答

合并多个单打，形成一个可观察

我写一个Android应用程序，它需要在以下顺序执行2个查询：提出要求（我们称之为RequestA）到返回Single<List<String>> urls库。根据我从RequestA收到的内容，我必须使用每个这些URL向另一个库发出请求（RequestB）。每个RequestB现在都返回一个Single。现在我已将所有RequestB中的所有Single合并为一个可观察对象。类似于Obs

0热度

1回答

RxJava如何观察旧版本的mainThread？我没有访问AndroidSchedulers.mainThread（）

Im建立一个项目使用web3。 web3j.ethGetBalance("0x2910543af39aba0cd09dbb2d50200b3e800a63d2", latestBlock) .observable() .subscribeOn(rx.schedulers.Schedulers.io()) //This needs to be on the

1热度

1回答

如何清理Rx Subscription和Observable以防止内存泄漏？

我正在研究一个项目，该项目频繁使用Rx Java订阅和观察值，而且我对这个概念非常陌生。我想知道处理它们的最佳做法是什么。目前，我只是将doOnUnsubscribe()函数中的订阅/观察值归零，并且使用takeUntil()和PublishSubject来触发观测值的断开连接。这是清理这些引用的正确方法还是有更好的方法？谢谢！

0热度

2回答

正确的方式来重复发射事件流的操作

我是RxJava的新手，所以我仍然试图让自己的头靠近它。我有一个Observable代表一串按钮点击，所以它很热。每次点击该按钮时，我都想做一些I/O。如果失败，我想重复并尝试再次执行该I/O，直到成功。这似乎是一个使用retry()或repeat()的好机会，但那些只能用于热门的可观察对象，而不是冷的。下面是一些伪代码来获得在我想要做的事： buttonRequests .map(a

0热度

1回答

使用RxAndroid进行翻新时出现重复文件异常

我想用RxAndroid进行翻新，因此我导入了如下所示的所需依赖项。但WHN我运行应用程序时，我收到以下错误： Error:Execution failed for task ':app:transformResourcesWithMergeJavaResForDebug'. > com.android.build.api.transform.TransformException: com.a

1热度

1回答

截断所有表格 - 房间

什么是截断房间库中所有表格的最快方式？我的目标是使用一个RxJava清除整个数据库CompletableFromAction。是否有可能创建从多个表中删除的@ Query？