Python
Java
PHP
IOS
Android
Nodejs
JavaScript
Html5
Windows
Ubuntu
Linux
Schedulers.io() 不返回主线程
我正在使用 RxParse 来解析查询的异步负载 但是当我使用 subscribeOn Schedulers io 订阅我的可观察值时 我的 onCompleted 方法永远不会在主线程上调用 相反 我的 onCompleted 方法是在工
Android
Multithreading
parseplatform
RXJava
RxAndroid
RxJava 棘手的 startWith(Observable)
以下代码仅在 observable2 完成后才从 observable1 发出项目 observable1 startWith observable2 subscribe 我需要实现另一种行为 observable1 gt 0 1 2 3
Java
Android
RXJava
reactiveprogramming
RxJava2
RxJava android mvp 单元测试 NullPointerException
我是 mvp 单元测试的新手 我想对演示者进行一个非常基本的测试 它负责登录 我只想断言 view onLoginSuccess 这是演示者代码 public LoginPresenter LoginViewContract loginVi
Java
Android
unittesting
RXJava
RXJava 调度程序/线程如何为不同的操作员工作?
谁能帮我解释下面的代码正在运行哪个调度程序 Completable complete subscribeOn http Schedulers io observeOn AndroidSchedulers mainThread delay 5
Android
RXJava
scheduler
返回 RxJava 的 Completable 的方法的命名约定
我有一个带有视图类的 Android 应用程序 Fragment Activity 观察其ViewModel The ViewModel公开方法 例如getUserName返回Observable
Android
RXJava
namingconventions
naming
reactive
何时取消订阅
我有一个关于如何取消订阅可观察的问题 我有两个代码 但我不确定哪一个更好 示例 1 gt 流结束后取消订阅订阅者 Subscriber
Android
RXJava
reactiveprogramming
RxAndroid
如何使用 Retrofit 2 和 RxJava 处理分页
我知道如何处理 Retrofit 响应 但在使用 rx java 处理来自 REST API 的分页时遇到问题 背景 我使用的其余 api 为我提供了以下响应 并在标题中提供了下一页的链接 HTTP 200 OK Allow GET HEA
Android
pagination
Retrofit
RXJava
Retrofit2
仅对布尔可观察值中的错误值进行反跳
我有一个布尔可观察值 通过观察者 启动和停止 Android 服务 当 true 被传递时 服务必须立即启动 当 false 被传递时 我想将其反跳 以防很快出现 true 以避免不必要的 和破坏性的 服务停止和启动 是否有可以做到这一点的
RXJava
使用 RxJava 限制吞吐量
我现在遇到的情况很难解释 所以我会写一个更简单的版本来解释这个问题 我有一个Observable from 它发出一系列由ArrayList文件数量 所有这些文件都应上传到服务器 为此 我有一个函数可以完成这项工作并返回一个Observab
Android
Multithreading
functionalprogramming
RXJava
Observable
RxJava、Proguard 和 sun.misc.Unsafe
我有以下问题RxJava 1 1 0 使用时Proguard 我没有更改 RxJava 版本或其 pro文件 但更新后OkHttp我无法编译使用Proguard因为我有关于sun misc Unsafe不在场 rxJava pro keep
Android
RXJava
RxAndroid
androidproguard
OkHttp
如何将 Observable
>> 转换为 Observable
>
我陷入了如何将以下可观察类型转换 转换为我的目标类型的困境 我有以下类型的可观察值 Observable
Java
RXJava
reactiveprogramming
RxJava2
用于请求带有临时缓存的远程 Observable 的 RxJava 模式
用例是这样的 我想暂时缓存最新发出的昂贵的Observable响应 但在它过期后 返回到昂贵的源Observable并再次缓存它 等等 一个非常基本的网络缓存场景 但我真的很难让它工作 private Observable
Java
Android
caching
RXJava
无需递归即可对可观察结果进行分页 - RxJava
我有一个非常标准的 API 分页问题 您可以通过一些简单的递归来处理 这是一个捏造的例子 public Observable
Java
pagination
RXJava
reactiveprogramming
Observable
重构 google 的 NetworkBoundResource 类以使用 RxJava 而不是 LiveData
谷歌的android架构组件教程here https developer android com topic libraries architecture guide html有一部分解释了如何抽象通过网络获取数据的逻辑 在其中 他们使用
Java
Android
RXJava
androidarchitecturecomponents
androidlivedata
如何使用 RxJava 处理分页?
我正在考虑将我的 Android 应用程序转换为使用 Rxjava 进行网络请求 我目前访问的网络服务类似于 getUsersByKeyword String query int limit int offset 据我了解 Observab
RXJava
RxAndroid - 单击时重试可观察
我在 Android 应用程序中使用 rxAndroid 和 rxKotlin 来异步处理网络请求 现在我想仅在单击 Snackbar 按钮后重试失败的网络请求 我现在的代码 val citiesService ApiFactory cit
Android
RXJava
Retrofit2
RxAndroid
rxkotlin
Single.zip - 如何捕获失败的呼叫并继续其余的网络呼叫?
我正在进行 5 个并行网络调用 模拟其中 4 个成功 其中 1 个失败 失败的调用使整个Single zip 失败 即使其他 4 个网络调用成功 我也无法获得它们的结果 如何处理单个失败的网络调用的错误Single zip 并获得成功者的结
Java
Android
RXJava
RxJava2
RxJava - 链接请求和更新 UI
我遇到的问题是这样的 我需要向服务器执行几个请求 下一个请求取决于前一个请求的结果 它们看起来像这样 缩写 Observable
Android
RXJava
具有自定义计数标准的 RxJava 缓冲区/窗口
我有一个 Observable 它发出许多对象 我想使用以下方法对这些对象进行分组 window or buffer运营 但是 不是指定count用于确定窗口中应有多少对象的参数我希望能够使用自定义标准 例如 假设可观察对象正在发出 a 的
kotlin
RXJava
RxJava2
如何创建无限间隔的 Observable 并在每个时间间隔发出新的对象?
我正在尝试创建一个每秒都会发出新对象的 Observable 所以现在我只是压缩一个 Observable 它以 Observable 间隔从列表中发出有限数量的对象 val list1 mutableListOf
kotlin
RXJava
RxJava2
1
2
3
4
5
6
...12
»