Python
Java
PHP
IOS
Android
Nodejs
JavaScript
Html5
Windows
Ubuntu
Linux
使用 RxJava 实现存储库模式
我正在尝试找出一种更好的方法来实现 Android 中 RxJava 中的存储库模式之类的功能 这是我到目前为止所拥有的 从here https gist github com pieces029 5e92f9003fa1a4ebc59b
Java
Android
RXJava
如何使用 RxJava 处理回收器视图的项目点击
我有兴趣找出响应回收器视图的项目点击的最佳方式是什么 通常 我会向 ViewHolder 添加一个 onclick 侦听器 并通过接口将结果传回活动 片段 我考虑过在 onBindViewHolder 中添加一个 Observable 但我
Android
androidrecyclerview
RXJava
RxAndroid
RxJava/RxAndroid 检查互联网连接是否可用
我有这个代码来检查互联网连接是否可用 public static boolean isOnline Runtime runtime Runtime getRuntime try Process ipProcess runtime exec
Java
Android
RXJava
RxAndroid
RxJava/RxAndroid - 处理多个 EditText 更改
我有 3 个 EditText 字段 并且为这些字段创建了 3 个可观察值 Observable
Java
Android
reactiveprogramming
RXJava
RxAndroid
RxJava:结合冷热观察来相互等待
我的可观察量是这样定义的 val initLoading Observable fromCallable println System currentTimeMillis subscribeOn Schedulers computation
Android
RXJava
RxJava2
rxkotlin
rxkotlin2
RxJava中concatMap和flatMap有什么区别
看起来这两个功能非常相似 他们有相同的签名 接受rx functions Func1
Java
RXJava
flatMap
concatmap
调试未收到消息的 RxJava 问题的最佳方法是什么
我有一个 Android 应用程序 其中包含多个A型观察者订阅多个B 类可观测量 订阅是在IO Scheduler中完成的 观察是在Android主线程上完成的 我遇到的问题是随机地经过一些工作后 A 从未收到 B 发出的一条消息 并且经过
Android
Multithreading
RXJava
Rxjava重试时立即调用
我对 rxjava 有一个非常具体的问题或误解 希望有人可以帮助解决 我正在运行 rxjava 2 1 5 并有以下代码片段 public static void main String args final Observable obse
Java
RXJava
RxJava重试时出现奇怪的行为
我正在玩 RxJava重试时间 http reactivex io documentation operators retry html操作员 网上关于它的资料很少 唯一值得一提的是this http blog danlew net 201
Java
RXJava
reactiveprogramming
仅在某些条件下使用什么 RxJava 运算符来链接可观察量
我正在 RxJava Android 中开发一个完整的应用程序 试图使事情尽可能成为 Rx 方式 我认为我已经实现了我想要的目标 但现在我遇到了一个问题 我确信存在更好的方法来做到这一点 它包括 从 Observable 获取布尔值 A 如
Android
RXJava
reactiveprogramming
RxJava:如何制作一次获取并重用的 Observable?
在每次应用程序启动时 我都有一个 Retrofit Observable 从服务器获取用户的用户名 我想为每个后续订阅者使用这个值 但似乎每次我调用 subscribe 时 都会从网络重新获取该值 由于用户名在应用程序的生命周期中不太可能更
Java
Android
RXJava
取消订阅 Single 的正确方法是什么[重复]
这个问题在这里已经有答案了 我想做一些短暂的延迟后 public void notifyMe Single timer 500 TimeUnit MILLISECONDS subscribeOn Schedulers io subscrib
Java
RXJava
RxJava2
使用 Retrofit 和 Realm 纠正 RxJava 中的流程
我正在结合 RxJava 和 Retrofit 来实现网络 API 并使用 Realm 作为数据库 我几乎可以正常工作 但我想知道这是否是正确的方法和事件流程 所以 这里是RetrofitApiManager public class Re
Android
Retrofit
Realm
RXJava
retrolambda
使用 RxJava 处理长时间运行的任务
我正在尝试迁移AsyncTask向服务器发送消息 使用 RxJava 粗略地说 该任务执行以下操作 1 创建一条将要发送的消息 保存到数据库 2 向用户显示消息 状态 正在发送 3 向服务器发送消息 代码片段如下 4 将消息标记为已发送或失
Android
RXJava
RxJava2
EventBus 和 RxJava 有什么区别? [复制]
这个问题在这里已经有答案了 我对 android 中的 EventBus 和 RxJava 之间的区别感到困惑 我需要实现其中之一来解决我的问题 即在完成某些更改后通知某些组件 以便它们可以更新其状态 另外 我读到 EventsBus 已因
Android
RXJava
EventBus
RXJava2:链接改造请求的正确模式
一般来说 我对 RXJava 比较陌生 实际上只是开始使用 RXJava2 而且我能找到的大多数文档往往是 RXJava1 现在我通常可以在两者之间进行转换 但是整个 Reactive 的东西太大了 它是一个压倒性的 API 并且有很好的文
Java
Android
RXJava
Retrofit2
RxJava2
如何避免重复常见的可观察配置?
我正在使用 Retrofit 在 Android 中编写一个 API 客户端 这种代 码会重复很多次 myObservableFromRetrofit subscribeOn Schedulers io observeOn AndroidS
Android
Retrofit
RXJava
为什么 Android 上的 RxJava with Retrofit doOnError() 不起作用,而 Subscriber onError 却起作用
有人可以解释一下为什么这样的代码 networApi getList subscribeOn Schedulers newThread observeOn AndroidSchedulers mainThread doOnError thr
Android
Retrofit
RXJava
RxAndroid
Subscriber
RxJava doOnError 与 onError
我尝试使用以下代码 initLocalSettingsIfNeed andThen initGlobalSettingsIfNeed configuration doOnComplete callback onSuccess doOnErr
Android
RXJava
RxJava2
立即交付第一个项目,“消除”后续项目
考虑以下用例 需要尽快交付第一个项目 need to debounce以下事件有 1 秒超时 我最终实现了基于的自定义运算符OperatorDebounceWithTime然后像这样使用它 lift new CustomOperatorDe
RXJava
RxAndroid
«
1
2
3
4
5
6
7
...11
»