Python
Java
PHP
IOS
Android
Nodejs
JavaScript
Html5
Windows
Ubuntu
Linux
可观察,出错时重试并仅在完成时缓存
我们可以使用cache 运算符来避免多次执行长任务 http请求 并重用其结果 Observable apiCall createApiCallObservable cache notice the cache the first time
RXJava
RxAndroid
如何处理 RxJava 中 Observable 中的 map() 中的异常
我想做这个 Observable just bitmap map new Func1
Java
Android
RXJava
RxAndroid
将 Single
> 转换为 Observable
?
Goal I get a Single
Java
RXJava
reactiveprogramming
如何过滤 RXJava 中 observable 发出的重复值?
我有一个对象集合 我想在其中抑制重复的项目 我知道关于Distinct http reactivex io documentation operators distinct html运算符 但如果我没有记错的话 它会通过正确覆盖的哈希码方法
Java
Distinct
RXJava
为什么我的 RxJava Flowable 在使用observeOn 时不考虑背压?
我正在尝试创建一个Flowable它会发出有关背压的事件以避免内存问题 同时并行运行转换的每个阶段以提高效率 我创建了一个简单的测试程序来推理程序不同步骤的行为以及何时发出事件与在不同阶段等待事件 我的程序如下 public static
Java
Multithreading
RXJava
ReactiveX
RXJava - 制作一个可暂停的可观察对象(例如带有缓冲区和窗口)
我想创建执行以下操作的可观察对象 在暂停时缓冲所有项目 立即发出项目 同时它们不会暂停 暂停 恢复触发器必须来自另一个可观察的 必须保存它才能供不在主线程上运行的可观察对象使用 并且必须保存更改主线程的暂停 恢复状态 我想用一个Behavi
Android
RXJava
Observable
Rx 2 Android 对于 api 调用,Single 或 Observable 哪个更好?
当我们使用 Retrofit2 通过 Rx 进行 API Rest 调用时 最好的使用方法是什么 单一还是可观察 public interface ApiService Single
Android
RXJava
Retrofit2
RxAndroid
使用 Retrofit observable 处理网络错误
当将 Observables 与 Retrofit 结合使用时 如何处理网络故障 鉴于此代码 Observable
Android
Observable
Retrofit
RXJava
使用 RxJava 进行电子邮件登录验证,可观察对象发出两次
我正在制作一个简单的登录表单 电子邮件和密码 来尝试增强我的反应式编程技能 我在让电子邮件字段验证按照我想要的方式工作时遇到一些问题 这是我的代码 final Observable
Java
Android
functionalprogramming
RXJava
reactiveprogramming
RxJava 并行获取 Observables
我需要一些帮助来在 RxJava 中实现并行异步调用 我选择了一个简单的用例 其中第一个调用获取 而不是搜索 要显示的产品列表 平铺 随后的调用将获取 A 评论和 B 产品图像 经过几次尝试我到达了这个地方 1 Observable
Java
Asynchronous
reactiveprogramming
Observable
RXJava
使用 RX Java 获取过滤器索引或第一个的优雅方法
我正在练习 RX Java 想要获取与过滤器匹配的项目在数组中的位置 我看不到任何明显的方法来做到这一点 我正在考虑压缩范围和可迭代可观察之类的东西 但它很快就变得比 for 循环更加冗长和复杂 过去有mapWithIndex and zi
Java
filter
RXJava
在后台运行 void 方法
我想使用 rxjava 在后台运行一个方法 我不在乎结果 void myHeavyMethod 到目前为止 我唯一的解决方案是将返回类型修改为例如boolean boolean myHeavyMethod return true 之后我运行
RXJava
RxJava2
RxJava-在 Observable 链中执行 peek() 或 void 操作?
Java 8 lambda 流有一个peek 运算符允许您对每个项目执行 void 操作 这通常用于调试 但它也是一种欺骗和启动 void 操作而不映射到某些内容的好方法 RxJava 中有类似的东西吗 也许我没有遵循良好的实践或反应性思考
Java
reactiveprogramming
RXJava
如何使用rxjava获取retrofit 2.0中的请求url?
我正在尝试升级到 Retrofit 2 0 并在我的 android 项目中添加 RxJava 我正在进行 api 调用 并希望检索 url 及其以及 sqlite 中的响应数据作为缓存 Observable
Android
RXJava
Retrofit2
何时使用 doOnTerminate 与 doOnUnsubscribe?
当有人订阅我的可观察对象时 我需要收到通知 我还需要收到通知 可观察对象已出错或已完成 所以我想我应该使用doOnSubscribe 注册观察者订阅时要采取的操作 可观察的 and doOnTerminate 注册一个 Observable
Android
RXJava
RxAndroid
如何在 RxJava 中延迟地从列表中发出项目?
我正在使用 Retrofit 从 REST API 获取书签 public interface BookmarkService GET bookmarks Observable
Android
Retrofit
RXJava
RxAndroid
如何在 RxJava 中计算移动平均线
在金融领域 我们通常需要从时间序列数据流中计算移动窗口总值 以移动平均线为例 假设我们有以下数据流 T是时间戳 V是实际值 T0 V0 T1 V1 T2 V2 T3 V3 T4 V4 T5 V5 T6 V6 T7 V7 T8 V8 T9 V
reactiveprogramming
RXJava
Rx:组合 ThrottleFirst 和 Sample 运算符
给定一个源可观察 S 我如何要求 RxJava Rx 生成可观察 D 即 立即从 S 发出第一项 在发射每个项目之后和发射下一个项目 L 之前等待至少 T 秒 其中 L 是 S 在等待期间发射的最后一个项目 如果 S 在等待时间 T 内没有
RXJava
重试时修改源 Observable - RxJava
如何在重试时更新可观察的源 List
RXJava
RxJava 2.x 中带有背压的 PublishSubject
我目前正在为我当前的项目选择 RxJava 1 x 或 2 x 我基本上需要一个PublishSubject采用背压策略onBackpressureLatest 我想选择 RxJava 2 x 但我不太清楚如何将反压策略应用于Publish
RXJava
RxJava2
1
2
3
4
5
6
...10
»