rx-java 相关问题

RxJava - JVM的Reactive Extensions - 一个库，用于使用Java VM的可观察序列组合异步和基于事件的程序。

带有MVVM和翻新的RXjava

我想将RxJava与MVVM一起使用，但我不明白为什么它不对我的Response类响应CompositeDisposable，所以我想对付RxJava，但我不知道如何链接...

android rx-java android-mvvm

回答 1 投票 0

Rxjava超时运算符，仅考虑从特定点发出的项目

我有一个带有一组运算符的rxjava可观察链。假设我有源Observable（总是每分钟发出项目），执行网络请求的操作员B和超时操作员。 ...

android timeout rx-java rx-java2

回答 1 投票 1

无法使用实现'androidx.room:room-rxjava2:2.1.0'在AndroidSchedulers.mainThread（）上解析符号'AndroidSchedulers'

我正在尝试遵循一些代码示例，以从数据库中提取一条记录以进行显示，因为使用LiveData这样做似乎有些复杂。但是，我在IDE中遇到错误。 ...

android rx-java android-room

回答 1 投票 0

我正在尝试将地图嵌套到RxJava2中的过滤器中，因此我可以删除所有没有正确平台的对象。但无法构建

覆盖有趣的getVideoGamesRepository（platformName：String）{gameRepo = VideoGameRepositoryImpl（）CompositeDisposable.add（gameRepo.returnVideoGames（）.filter {gameModel-> ...

android kotlin rx-java

回答 1 投票 0

泛型函数签名中where关键字的用途是什么？

我重构了此代码段：remark.observeOn（mainThread（））.subscribe {备注-> remark_box.visible = remark.isNotEmpty（）remark_tv.text =备注} .addTo（...

android generics kotlin refactoring rx-java

回答 1 投票 0

Kotlin中哪个函数具有泛型关键字？

我重构了此代码段：remark.observeOn（mainThread（））.subscribe {备注-> remark_box.visible = remark.isNotEmpty（）remark_tv.text =备注} .addTo（...

android generics kotlin refactoring rx-java

回答 1 投票 -1

处理来自发布者的同等消耗的数据

如何处理从Publisher并行订阅的数据？我是否应该在一群工人中循环订阅？当我在Project Reactor中调用subscription时，我仅获得了一大块数据。如何“排干所有”？ ...

java rx-java project-reactor reactive-streams

回答 1 投票 0

如何使用RxJava为Retrofit API创建包装器

我有两个API，分别是API 1和API2。API1获取身份验证令牌，API 2获取用户个人资料信息。我需要从ViewModel中访问API 2，但是如果API 2提供了身份验证错误，那么我需要获取...

android rx-java retrofit2

回答 1 投票 2

使用存储库模式在后台处理蓝牙流的最佳方法是什么？

我需要一个频率为1Hz的蓝牙连接处理程序，其使用方式类似于存储库模式，将数据保存在SQliteDB中，并在应用程序的多个视图上显示信息。我当前的选择是...

android performance bluetooth rx-java rx-android

回答 1 投票 0

是否可以从Reactor Flux或RxJava2 Observable / Flowable到AkkaStreams源使用适配器？

有时有一些库，例如R2DBC，它返回一个Reactive Stream，即Reactor Flux，但是在Http层中，我们需要另一个Reactive Stream，即AkkaStreams Source，它是AkkaHttp ...

akka rx-java project-reactor akka-stream reactor

回答 1 投票 0

为什么线程在回调中更改为主线程？

我正在使用Kotlin和RxJava开发一个android应用。我使用android最新API开发了应用内结算。但是该库仅支持异步回调。因此，我编写了如下代码：私人娱乐...

android kotlin rx-java

回答 1 投票 0

流发布者到java9中的字符串

如何从Flow.Publisher 正文中获取字符串？我只想从Publisher中解析字符串。

java rx-java

回答 1 投票 0

我如何将throwable传播到Completable的下一个链？

我正在使用RxJava开发一个Android应用。我有一些API调用链。验证消耗val验证= Completable.error（Exception（“ TEST”））.doOnSubscribe {Log.d（TAG，“ 1. verify”）} ...

android rx-java rx-java2

回答 1 投票 0

在Akka中是否可以像RxJava / Reactor一样从Source => Source函数创建Flow？

我仍然没有找到在AkkaStreams中进行“过滤”流程的简便方法。使用fromFunction对我来说很容易执行“映射”流程，但是对我却不行。在RxJava / Reactor中有一个...

akka rx-java akka-stream

回答 1 投票 1

如何从rxjava中的列表中执行过滤操作符

下午好。所以我得到了一个列表，里面是这样的列表：{“ category”：[{“ name”：“ Bathroom”，“ products”：[{“ name”：“ Sink01”}，{...

kotlin rx-java rx-kotlin

回答 1 投票 1

RxJava合并/合并对象与列表

我有2个可观察值，一个返回1个元素，另一个返回多个元素。我的目标是无障碍地将它们合并在一起，以构建如下对象：class Combined {...

rx-java

回答 1 投票 0

[RxJavaSwing + MVVM带有纵向横向视图

在我的Java桌面项目中，使用[RxJavaSwing] https://github.com/akarnokd/RxJavaSwing、[RxJava3] https://github.com/ReactiveX/RxJava，遵循Petikoch示例提供的MVVM体系结构https：// ...

java swing mvvm rx-java

回答 1 投票 0

RX Java将可观察变量与一对多关系结合起来

我有一个Observer对象，该对象已在Observable上订阅。该Observable对数据库执行SQL查询，获取多个结果，然后执行.forEach（...）现在，我需要添加第二个SQL ...

java rx-java reactive-programming rx-java2

回答 1 投票 0

调用JobIntentService的onDestroy后会发生什么？

我有一个与JobIntentService的生命周期有关的问题。从文档中，我发现在onHandleWork（Intent intent）返回后，JobIntentService被销毁了。 ...

android observable rx-java android-jobscheduler jobintentservice

回答 1 投票 0

如何将对象从flatMap传递到链中的subscribe？

如何从flatMap中传递对象以进行链式订阅？在下面的代码片段中，如何在链中访问博客对象？单个 > ...