rx-android 相关问题

如何使用doOnNext，doOnSubscribe和doOnComplete？

RxJava2 / RxAndroid和Android开发的新手，但对Java非常熟悉。但是，在尝试“优化”并能够在一堆...

RXJAVA ROOM android

[尝试学习Room和RXJAVA。我大约有80％的理解，但是我被困在弄清楚其余的事情上。这是我在插入数据上遇到的错误。 java.lang.NullPointerException：...

ViewModel观察针对API的一次点击多次运行

我有一个图表片段和一个开关。在选择开关时，需要再次使用新值来命中API，并且需要更新图表，API代码如下所示：private fun hitSecondChartApi（...

ViewAPI观察被触发两次以上，而API仅被击中一次

viewmodel观察在片段和活动中连续触发同一事件多次（3-4）。这是视图模型代码：userModel.getResponseSuperRegion（countryID ... ...

是否需要处置SingleObserver？如果是，在哪里？

我有以下一段代码Single.just（settings.toString（））.observeOn（AndroidSchedulers.mainThread（））.subscribe（new SingleObserver （）{private Disposable一次性； ...

使用翻新和rxjava Android的多个并行api请求

我是Rx Java的新手，我想从多个API中获取数据。这些API彼此独立，但是我想在View中显示这些API的数据。所以我想做...

RxAndroid`Observable…subscribe`在Android Studio中突出显示

我正在使用RxAndroid将背景线程中的字符串编组到主线程中，并对该主线程上的字符串进行处理：String stringFromDatabase = readFromDatabase（）; ...

如何将Function3转换为并行打2个API，而不是3个或更多？

我正在使用以下方式并行命中3个API，因为我想看到像Function4、5、6，如果您想命中更多API但没有Function2 那么如何使用命中2个API？ ...

如何使用Observable.zip（…）来获取API响应？

我必须点击3个API才能更新同一屏幕，因此，我认为RxJava是并行执行此操作的最快方法。在搜索实现时，我遇到了Observable.zip（...）...

RxJava2：如何在处置订阅者后避免InterruptibleException？

我有一个可观察对象：public Observable > getConversationListObservable（）{返回Observable.create（发射器-> {List 对话= ...

rxjava后台进程和中间更新ui

冗长的后台操作，并且具有FOR循环。循环中的每次迭代完成后，我需要更新UI。我如何才能在RX Java中实现这一点而无需等待所有迭代都得到...

如何为多个可观察对象设置超时时间

我有一个场景，我有两个可观察对象，每个都从API调用返回一个项目。我想做的是：同时执行两个api调用。为两个...设置超时值（500毫秒）...

RxJava：在发出另一个可观察对象的数据之前，阻止一个可观察对象发出]]

下面的代码块设计为脱机优先。如果数据是由可观察的内存发出的，则本地和远程可观察的对象将永远不会触发。如果数据未保存在内存中，则本地可观察到的...

从rxBleDevice读取特征在Android中给出了例外，在iOS中为什么使用相同的UUID可以正常工作

当前，我正在使用一个涉及从ble设备读取数据的应用程序。我正在尝试从Andesfit温度计，Andesfit血压，Andesfit体重秤读取数据。 ...

如何解析Kotlin MVVM数据绑定中的Json

[我正在尝试通过以下Json字符串实现它：{“ msg”：[“ football”，“板球”，“棒球”，“橄榄球”，“海湾”]，“ status”：“成功”}我已经创建了数据...

[RXJava Observable仅当以Observer作为匿名类型订阅时才发出项目

当我以匿名类型创建新的Observer时，它工作正常：Observable > postsListObservable = mApplicationAPI.getPosts（）; postsListObservable。 ...

如果只有另一个流已经发出了项目并且在Rxjava中没有使用它，我该如何发出它

我的问题看起来很简单，但请参阅下文。流字母：----------------------（A）---------------------- ------（B）-----流号：---（1）-----（2）------------------（ 3）----（4）----（5）-...

带有rxjava的迭代列表Android房间，一一

我有从room db获取的列表，我想使用rxjava逐一获取该列表项。当我添加consumer和flowable时，它仅给出第一个索引，因此将其添加为单个索引。它正在工作...

Observable fromIterable不要将项目插入房间

我面对一个非常奇怪的问题，不知道为什么会这样。当我具有fromIterable的流以一一插入到Room项目时，它不会插入。没有例外，没有。我什至把...

如何在RxJava地图操作符内部使应用程序崩溃

例如，当调用RxJava地图运算符后发生NullPointerException时，应用程序不会崩溃。我希望应用程序在发生这种情况时崩溃，以便它可以将报告提交给crashlytics等。...