Python
Java
PHP
IOS
Android
Nodejs
JavaScript
Html5
Windows
Ubuntu
Linux
带有 vararg observables 的 RxJava zip
当我们确切地知道有多少个具有确切类型的可观察量并且我们想要压缩时 我们会这样做 Observable
Java
reactiveprogramming
RXJava
在 RxJava 中,如何在错误时重试/恢复,而不是完成可观察的
我想要实现的是 监控特定变化的偏好 当检测到更改时 使用新值启动新的网络调用 变换结果 在 UI 中显示结果 我知道更改何时发生 现在我认为我需要对某个主题调用 onNext 然后这应该会触发 Rx 链 最后我可以更新 UI mViewPe
Java
Android
RXJava
RxAndroid
如何在BehaviorSubject中设置默认值
可能是一个菜鸟问题 如何为BehaviorSubject 设置默认值 我有一个具有 2 个不同值的枚举 enum class WidgetState HIDDEN VISIBLE 以及发出状态的行为主体 val widgetStateEmi
Android
kotlin
RXJava
Java反应式框架的比较[关闭]
Closed 这个问题是基于意见的 help closed questions 目前不接受答案 我看到许多框架 库声称它们可以帮助用 Java 构建响应式应用程序 例如 Akka Vert x RxJava Reactor QBit 等 他
Java
akka
reactiveprogramming
RXJava
projectreactor
在 RxJava 2 中展平列表
我已经使用 RxJava 1 一段时间了 但我想看看 RxJava 2 在 RxJava 1 中 我可以发出列表中的每个项目 如下所示 List
Java
RXJava
RxJava2
基于内容的 RxJava Observable 缓冲区
我使用 vertX 和 RxJava 启动了一个项目 但遇到了一个问题 但没有找到解决方案 我有一个 Observable 它为传入通信发出 WebSocketFrame 每个 WebSocketFrame 由有效负载 ByteBuffer
RXJava
Observable
Rxjava - 链接可观察量时如何获取其他类型的流(返回值)而不是当前的流?
我执行了一个 Retrofit2 observable 调用 在完成后它立即链接到另一个 observable 以将结果存储到数据库中 它看起来很简单 如下所示 protected Observable
Java
RXJava
RxJava 中的 n 元笛卡尔积
现在我持有一个Observable
Java
Math
RXJava
RxJava2
使用 Schedulers 时,System.out.println 在 RxJava 中不打印任何内容
我正在摆弄 RxJava 和调度程序 我用调度程序实现了一个非常简单的流 Observable just 1 2 3 doOnNext v gt Thread currentThread getName subscribeOn Schedu
Java
Multithreading
scheduler
RXJava
RxJava 中的笛卡尔积
是否有可能在rxjava中获得两个Observables的笛卡尔积 像这样的事情 A gt 1 2 3 B gt a b A x B gt 1 a 1 b 2 a 2 b 3 a 3 b 你想要的是 对于一个数字 产生与你有字母一样的一对
Java
RXJava
仅当其中一个流发生更改时,combineLatest 才会发出
我有一个具有频繁值的流和一个具有较慢值的流 我想将它们组合起来 但仅当较慢的发出时才发出一个值 所以combineLatest不起作用 就像这样 a1 a2 b1 a2 b1 a3 a4 a5 b2 a5 b2 目前我正在这样做 有没有更干
scala
reactiveprogramming
RXJava
RxJava 作为事件总线?
我开始学习 RxJava 到目前为止我很喜欢它 我有一个片段与单击按钮时的活动进行通信 用新片段替换当前片段 谷歌推荐界面 http developer android com training basics fragments commu
Android
androidfragments
RXJava
EventBus
如何使用一个可观察量的状态来跳过另一个可观察量的值?
通过一个简短的例子可以最好地解释这一点 假设这是我想要过滤的可观察源 Observable interval 1 TimeUnit SECONDS 我使用复选框来处理过滤器状态 当未选中该框时 我想跳过所有值 我使用 RxAndroid 来
Java
RXJava
RxAndroid
RxJava,改造错误:预期为 BEGIN_ARRAY,但在第 1 行第 2 列路径 $ 处为 BEGIN_OBJECT
我正在使用改造和RxJava库并尝试解析此网址 https api myjson com bins tdze5 我的代码如下 API接口 java public interface APIService GET bins tdze5 Obs
Android
json
RXJava
Retrofit2
Gson
如何使用 Retrofit 和 RxJava/RxAndroid 处理响应错误?
我无法弄清楚如何使用改造和 RxAndroid 处理响应错误 如果存在网络错误等 则会调用 onError 但我需要能够获取响应以检查是否存在身份验证错误 相反 我得到的是一个带有空字符串的令牌 但我找不到原因 解决这个问题的最佳方法是什么
Java
Android
Retrofit
RXJava
RxAndroid
当返回自定义对象列表时,RxJava 突出显示错误但编译
我正在进行 RxJava 调用 我订阅的最终结果是预订列表 代码工作正常 但我得到了这个恼人的亮点 演员阵容在这里不起作用 因为我无法演员阵容List
Java
RXJava
RxJava + 改造,获取列表并为每个项目添加额外信息
我正在玩 RXJava 在 Android 中进行改造 我正在努力完成以下任务 我需要定期轮询一个给我 Observable gt 的调用 从这里我可以做到 一旦我得到这个列表 我想在每个交付中迭代并调用另一个方法来给我预计到达时间 所以只
Android
polling
Retrofit
Observable
RXJava
如何在改造多部分请求中发送对象数组
I want to send array objects with multipart data I tried many ways but it is not working My issue with the contributor p
Android
kotlin
Retrofit
RXJava
用于改造响应代码处理的自定义 rx Func1
我是 rxjava 的新手 所以请不要严格 我请求虱子下一个 Observable
Android
RXJava
Retrofit2
RxAndroid
HTTP 失败:java.net.SocketException:套接字已关闭;不启动异常处理方法
我有一个 RxJava 链请求 应该释放一些 onError 或 onComplete 锁 所以 基本上 我的问题是 当我为 OkHttpClient 设置读取 连接和写入超时时 我没有得到所需的行为 我正在使用 Retrofit2 和 O
Android
RXJava
Retrofit2
OkHttp
1
2
3
4
5
6
...11
»