Python
Java
PHP
IOS
Android
Nodejs
JavaScript
Html5
Windows
Ubuntu
Linux
RXJava 忽略错误并继续链
我有一个 RXJava 链 可以抛出错误 我希望链继续并忽略错误并到达订阅 仅针对某些特定错误 例如在这段代码中 authDataManager getUserAccessToken username password subscribeO
Java
Android
kotlin
RXJava
如何并行执行 2 个 Observable,忽略它们的结果并执行下一个 Observable
我必须并行执行 2 个 observable 不关心它们的输出 当它们都完成时 gt 运行另一个 observable 这是我的解决方案 但我觉得还有更好的解决方案 rx Observable
Java
RXJava
Android中使用Retrofit和RxJava从JSON数组中一一获取JSON对象
我正在使用 Retrofit 来访问返回 json 数组的网络 api 我正在使用以下代码这样做 Observable
Android
json
RXJava
Retrofit2
RxAndroid
在 Android 上什么时候应该使用 RxJava Observable,什么时候应该使用简单的 Callback?
我正在为我的应用程序开发网络 所以我决定尝试一下 Square 的Retrofit https github com square retrofit 我看到他们支持简单的Callback GET user id photo void get
Android
Retrofit
RXJava
Rx 中立即去抖
我正在寻找一位运营商debounce一系列的事件 比如说用户的点击 输入和输出应该是这样的 interval gt lt gt lt in 1 2 3 4 5 5 6 7 8 out 1 4 这个想法就像下划线的反跳immediate op
RXJava
rxjs
systemreactive
debouncing
当 Observable/Completed 完成或释放时,RxJava2 获取事件
当我订阅时我需要显示一个进度对话框Completable并在操作完成 成功或有错误 或取消后隐藏它 So I do final Completable completable notificationRepository markAllAs
Android
RXJava
RxJava2
TransformClassesWithDesugarForDebug 出错
我在编译 APK 调试或发布 时遇到问题 Android Studio 3 0 Beta 5 这是我的构建 gradle app buildscript repositories maven url https maven fabric i
Android
Gradle
androidgradleplugin
RXJava
buildgradle
重用订阅者
在 RxJava 中我有一个Subscriber我订阅的对象Observable 稍后 一段时间后onComplete 已被调用 我创建一个新的Observable并以相同的方式订阅Subscriber之前使用过的实例 然而 这似乎行不通
Java
reactiveprogramming
RXJava
如何在 RxJava 中的动态列表上创建观察者?
我需要在不断变化的数组上创建一个观察者 添加元素 我正在使用 Observable from Iterable 但它似乎在 ArrayList 上创建了 Observable 就像创建时一样 我需要通知观察者并在每次 ArrayList 添
RXJava
执行操作符而不是整个订阅者
使用起来相当有吸引力Action s 而不是整个Subscriber当你只需要OnNext 只是因为它更具可读性 但当然 错误会发生 如果你只使用Action1你会得到一个Exception在你的应用程序中 do 运营商 http reac
Java
reactiveprogramming
RXJava
Rx - 如何在收到 onNext() 后自动取消订阅?
如何在收到 onNext 后自动取消订阅 现在我使用这段代码 rxObservable compose bindToLifecycle unsubscribe automatically in onPause if method was c
RXJava
RxAndroid
如何使用 switchIfEmpty RxJava
这里的逻辑是 如果数据库中的评级为空 那么我想从 API 中获取它们 我有以下代码 Observable from settingsRatingRepository getRatingsFromDB toList switchIfEmpty
Java
Android
RXJava
Android:使用repeatWhen、takeUntil和带改造的过滤器通过rx-java无限滚动
我正在使用 Retrofit 2 2 和 RxJava 分页是这样工作的 我得到第一批数据 我必须请求具有相同参数的第二批数据 除了最后更新日期 然后如果我得到空或同一批数据 则意味着有没有更多的物品 我发现了这篇很棒的文章https me
Android
RXJava
Retrofit2
RxAndroid
RxJava 使用可观察对象为 Android 构建缓存
我很难理解如何使用 RxJava 构建缓存 我的想法是 我需要从内存缓存获取数据或从数据库 dynamoDb 加载数据 但是 该缓存应该在片段和 或线程之间共享 所以我需要返回当前正在运行且未完成的现有可观察对象 这允许线程赶上而不做不必要
Java
Android
caching
RXJava
Retrofit 和 RxJava:如何组合两个请求并访问两个结果?
我需要提出两个服务请求并将其结果合并 服务 gt id 1 name title id 1 name title 服务B id gt field value field1 value 目前 我已成功合并结果 但我需要通过id作为参数Serv
Java
Android
RXJava
Retrofit2
RxJava 适合分支工作流程吗?
我正在使用 RxJava 来处理我们从队列中提取的一些通知 RxJava seemed to work fine with a simple workflow now with new requirements coming in the
Java
functionalprogramming
RXJava
reactiveprogramming
RxJava2
两个有序可观察量的完全外连接
假设我们有两个可观察量Observable
join
RXJava
RxJava2
RxJava:将一个流(Observable)作为另一个流的输入
我还在学习 RxJava 在另一个流中使用一个流的最佳方式是什么 或者说这违反了反应式编程的原则 我试图编写的一个玩具示例包括一个 TCP 客户端和一个发回大写输入的服务器 我想从标准输入获取输入 将其发送到服务器并打印出客户端和服务器收到
reactiveprogramming
RXJava
使用retrofit和rxjava重复进行API调用
我有一个可观察到的改造 GET something Observable
Java
Android
Retrofit
RXJava
Retrofit2
反应式和非阻塞方法 Micronaut 与 apache kafka
我试图从 Micronaut kafka 实现中获取非阻塞响应 但是返回值不起作用 public class ProductManager implements IProductManager private final Applicati
Java
RXJava
micronaut
micronautrest
micronautkafka
«
1 ...
5
6
7
8
9
10
11
»