RxJava - JVM的Reactive Extensions - 一个库,用于使用Java VM的可观察序列组合异步和基于事件的程序。
我在演示者内部有以下代码。公共类SignUpPresenter实现了Presenter {私有CompositeDisposable一次性用品;私人视图视图; @Inject public ...
我正在实现我的第一个WorkManager,用于与服务器每日同步,这可能会返回HTTP错误,因此使createWork()流失败并调用onError(),因此Result.failure()被“抛出” ...
[我是否可以通过一种方法来组合Maybes,使之基本上可以合并Observables:-制作一个新的Maybe,它等待一系列Maybes发出光,然后制作一个新的Maybe,它发出一个项目(...
我想为此搜索我的应用程序,我想根据它们的名称同时查询两个表,并且只要它在...中找到相关名称,就想返回结果。 [
覆盖乐趣onViewCreated(view:View,savedInstanceState:Bundle?){super.onViewCreated(view,savedInstanceState)// ViewModelFolder.selectFolder是MutableLiveData ViewModelFolder ....
Flow API中的subscription.request(n)如何以任何n值执行背压?
我正在使用Flow API,到目前为止,我了解到request()方法用于背压。大多数文章指出,这类似于控制消费速度。 ...
我有一个图表片段和一个开关。在选择开关时,需要再次使用新值来命中API,并且需要更新图表,API代码如下所示:private fun hitSecondChartApi(...
我试图使用RxJava多线程加快计算速度,但是并行计算比顺序计算要花更多的时间。我在数组中有数百个值。对于每个值,我都需要做长...
我的应用程序弹出ANR(应用程序没有响应)对话框。长期以来,我一直在努力解决这个问题。我做了很多优化,最后我的主线程占用了2到300万个...
我正在尝试在recyclerview中实现搜索选项。到目前为止,我已经实现的是:创建一个如下所示的搜索栏:我已经在MainActivity中按照以下方式应用onCreateOptions:class ...
了解RxJava中的Observable.fromArray
我正在尝试学习RxJava的不同运算符。我对Observable.just和Observable.fromArray()以及它们如何发出Observable感到有些困惑。单个整数可以正常工作,但是对...
无法使用Kotlin,Retrofit,RxJava和MVVM模式解析嵌套的JSON
[在我的项目中,我遇到了一些有关在MVVM模式中使用Kotlin,Retrofit和RxJava返回嵌套JSON数据的问题。我对RxJava,MVVM和Retrofit比较陌生,相当...
viewmodel观察在片段和活动中连续触发同一事件多次(3-4)。这是视图模型代码:userModel.getResponseSuperRegion(countryID ... ...
我想使用Rx处理串行端口数据,其数据包结构如下所示。 + ----------- + -------- + --------- + |签名|长度有效载荷+ ----------- + -------- + --------- + | 2 ...
RxJava上的运算符Observable / Flowable延迟发射n个项目
我想对Flowable进行转换,以使其延迟发射项目,直到收集到指定数量的项目为止,然后按照FIFO顺序将它们发射到下游,以保持恒定的延迟项目...