Python
Java
PHP
IOS
Android
Nodejs
JavaScript
Html5
Windows
Ubuntu
Linux
Single.zip - 如何捕获失败的呼叫并继续其余的网络呼叫?
我正在进行 5 个并行网络调用 模拟其中 4 个成功 其中 1 个失败 失败的调用使整个Single zip 失败 即使其他 4 个网络调用成功 我也无法获得它们的结果 如何处理单个失败的网络调用的错误Single zip 并获得成功者的结
Java
Android
RXJava
RxJava2
具有自定义计数标准的 RxJava 缓冲区/窗口
我有一个 Observable 它发出许多对象 我想使用以下方法对这些对象进行分组 window or buffer运营 但是 不是指定count用于确定窗口中应有多少对象的参数我希望能够使用自定义标准 例如 假设可观察对象正在发出 a 的
kotlin
RXJava
RxJava2
如何创建无限间隔的 Observable 并在每个时间间隔发出新的对象?
我正在尝试创建一个每秒都会发出新对象的 Observable 所以现在我只是压缩一个 Observable 它以 Observable 间隔从列表中发出有限数量的对象 val list1 mutableListOf
kotlin
RXJava
RxJava2
使用 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
1
2
3
4
»