Python
Java
PHP
IOS
Android
Nodejs
JavaScript
Html5
Windows
Ubuntu
Linux
使用 RxJava 和 Retrofit 实现 Room
我正在尝试将 Room 与 RxJava 和 Retrofit 一起使用 在您建议使用组件架构之前 在这个机会是不可能的 该项目已完成 50 只需继续清理架构 So the problem这是 我有一个网络服务返回POJO 像这样的东西 s
Android
Retrofit2
RxJava2
androidroom
cleanarchitecture
在 RxJava 2 中展平列表
我已经使用 RxJava 1 一段时间了 但我想看看 RxJava 2 在 RxJava 1 中 我可以发出列表中的每个项目 如下所示 List
Java
RXJava
RxJava2
Picasso + RxJava2:方法调用应该从主线程发生
这是我最初的问题 我试图在其中显示一些图像AutoScrollViewPager 我正在使用毕加索来实现同样的目的 但是 我想使用 Rxjava2 Picasso 做同样的事情 我对 RxJava 概念有点陌生 因此 如果有人可以帮助我提供
Java
Android
picasso
RxJava2
RxJava 中的 n 元笛卡尔积
现在我持有一个Observable
Java
Math
RXJava
RxJava2
在后台运行 void 方法
我想使用 rxjava 在后台运行一个方法 我不在乎结果 void myHeavyMethod 到目前为止 我唯一的解决方案是将返回类型修改为例如boolean boolean myHeavyMethod return true 之后我运行
RXJava
RxJava2
如何取消订阅广播接收器中的 RXjava 调用
我正在使用 RXJava2 在广播接收器内发送电子邮件 我想知道何时应该取消订阅该事件 代码基本上是 getSmsMmsObservable subscribeOn Schedulers io observeOn AndroidSchedu
Android
BroadCastReceiver
RxJava2
RxJava2 - 同步执行调用
I ve a TestService 我在其中执行异步任务来获取数据 我想等待回复后再继续 public List
Android
RxJava2
架构组件改造和 RxJava 2 错误处理
我目前正在尝试使用来自改造和 Okhttp 的 API 请求在架构组件中实现新的 ViewModel 一切正常 但我不知道如何将错误响应从改造传递到LiveDataReactiveStreams fromPublisher然后上游到片段中的
Android
Retrofit2
RxJava2
androidarchitecturecomponents
RxJava 2.x 中带有背压的 PublishSubject
我目前正在为我当前的项目选择 RxJava 1 x 或 2 x 我基本上需要一个PublishSubject采用背压策略onBackpressureLatest 我想选择 RxJava 2 x 但我不太清楚如何将反压策略应用于Publish
RXJava
RxJava2
RxJava 2 中的映射异常
如何将 RxJava2 中发生的一个异常映射到另一个异常 例如 doOnError throwable gt if throwable instanceof FooException throw new BarException 在这种情况
Java
Exception
reactiveprogramming
RxJava2
为什么不调用 doOnDispose?
当创建这样的 Observable 时 public void foo Observable observable Observable fromCallable gt bar return doOnSubscribe disposable
Java
RXJava
RxJava2
rxjava3
Dagger 生成改造拦截器的多个实例
我是 Dagger 和 Retrofit 的新手 我遇到的问题是 尽管在 dagger 模块中声明了单例 但仍生成了多个改造自定义拦截器实例 我只需要一个实例 匕首模块 Module public class ApiModule priva
Android
Retrofit2
Dagger2
RxJava2
使用 RxJava 时如何重试 HTTP 错误 (401) 的 Retrofit 调用?
我当前的 Android 应用程序正在使用Retrofit 2 4 0 and RxJava 2 1 16 执行我的 Web 服务调用 我正在使用 Google 登录进行用户身份验证 我希望我的 Retrofit 调用能够检测 HTTP 4
Android
Retrofit2
RxJava2
RxJava 对列表执行操作并返回可观察值
我是 RxJava 特别是 RxJava2 的新手 并且在看似相对简单的操作中遇到了一些麻烦 我需要从数据库获取一些数据 迭代数据 它表示为列表 对每个项目执行操作 将数据包装在另一个对象中并返回 这是我到目前为止所拥有的 mDataMan
Java
Android
RXJava
reactiveprogramming
RxJava2
RxJava API 和 Java 9 Flow API 之间的区别
在过去几个主要版本的 Java 的每次迭代中 似乎都有一致的新方法来管理并发任务 在 Java 9 中 我们有Flow API https docs oracle com javase 9 docs api index html java
Java
RXJava
RxJava2
java9
RxJava:结合冷热观察来相互等待
我的可观察量是这样定义的 val initLoading Observable fromCallable println System currentTimeMillis subscribeOn Schedulers computation
Android
RXJava
RxJava2
rxkotlin
rxkotlin2
HTTP 失败:java.net.SocketException:套接字关闭改造
尝试了多种方法仍然面临这个问题 我正在使用 RxJava 和 Retrofit 来完成所有网络操作 下面是我的代码 服务 kt GET v1 contact id fun getContactDetails Path id id Strin
Android
Retrofit2
RxJava2
取消订阅 Single 的正确方法是什么[重复]
这个问题在这里已经有答案了 我想做一些短暂的延迟后 public void notifyMe Single timer 500 TimeUnit MILLISECONDS subscribeOn Schedulers io subscrib
Java
RXJava
RxJava2
使用 RxJava 处理长时间运行的任务
我正在尝试迁移AsyncTask向服务器发送消息 使用 RxJava 粗略地说 该任务执行以下操作 1 创建一条将要发送的消息 保存到数据库 2 向用户显示消息 状态 正在发送 3 向服务器发送消息 代码片段如下 4 将消息标记为已发送或失
Android
RXJava
RxJava2
如何在Android RxJava中使用flatMap在不使用lambda函数的情况下顺序调用三个Web服务?
我的 API 客户端 public class ApiClient public static final String BASE URL http baseurl com wp json private static Retrofit r
Android
Retrofit2
RxJava2
1
2
3
4
»