Python
Java
PHP
IOS
Android
Nodejs
JavaScript
Html5
Windows
Ubuntu
Linux
重试时修改源 Observable - RxJava
如何在重试时更新可观察的源 List
RXJava
RxJava 2.x 中带有背压的 PublishSubject
我目前正在为我当前的项目选择 RxJava 1 x 或 2 x 我基本上需要一个PublishSubject采用背压策略onBackpressureLatest 我想选择 RxJava 2 x 但我不太清楚如何将反压策略应用于Publish
RXJava
RxJava2
发生特定情况时如何停止 Kotlin 流程
如果代码中发生某些情况 我想取消 kotlin 流程 假设我有一个方法如下 fun test Flow
Asynchronous
kotlin
RXJava
reactiveprogramming
kotlinflow
RxJava Observable.fromEmitter 奇怪的背压行为
我一直在利用Observable fromEmitter 作为一个绝佳的替代品Observable create 我最近遇到了一些奇怪的行为 但我不太明白为什么会出现这种情况 我真的很感谢对背压和调度程序有一定了解的人来看看这个 publi
Java
RXJava
使用 OkHttp、Okio 和 RxJava 下载文件
我正在尝试使用 OkHttp 下载文件并使用 Okio 写入磁盘 我还为此过程创建了一个 rx observable 它正在工作 但是它比我以前使用的 Koush 的 Ion 库 明显慢 以下是我创建可观察对象的方法 public Obse
Android
RXJava
OkHttp
RxAndroid
okio
为什么不调用 doOnDispose?
当创建这样的 Observable 时 public void foo Observable observable Observable fromCallable gt bar return doOnSubscribe disposable
Java
RXJava
RxJava2
rxjava3
RxJava,一个可观察多个订阅者:publish().autoConnect()
我正在使用 rxJava rxAndroid 但有一些非常基本的东西没有按照我的预期运行 我有一个可观察对象和两个订阅者 Observable
RXJava
reactiveprogramming
RxJava 出错后如何继续流式传输项目?
我是 RxJava 新手 我遇到了以下问题 假设我有一系列项目 并且其中一个项目传播错误 我想忽略它并继续处理其他项目 我有以下片段 Observable from Arrays asList 1 2 3 map x gt if x equ
Java
RXJava
reactiveprogramming
RxAndroid
RxJava:尝试将错误传播到 Observer.onError 时发生错误
我在 Rx 库中收到 IllegalStateException 错误 并且不知道问题的根源在哪里 无论是 RxJava 还是我可能做错的事情 当证书固定 发生在所有服务器请求上 但似乎指向会话超时或注销并返回时 会发生致命崩溃 重现步骤
Android
Exception
RXJava
onerror
RxAndroid
subject.asObservable 有什么用?
为什么需要RxJavaasObservable 从技术上讲 每个主题都已经是一个可观察的 它比仅仅铸造它有什么优势 Observable obs subject 如果你只是投Subject to an Observable那么你仍然可以使用
RXJava
如何从列表中发出每个项目之间有延迟的项目?
我想从列表中发出项目 并且在每次发射之间我想要一个延迟 我试过这个 final Subscription subscription Observable from listOfItems delay 2000 TimeUnit MILLIS
list
DELAY
RXJava
RxJava + Retrofit -> BaseObservable 用于 API 调用以进行集中响应处理
我是 RxJava 新手 所以如果这听起来太新手 请原谅我 截至目前 我有一个实现 Retofit 回调的抽象 CallbackClass 在那里 我捕获了回调的 onResponse 和 onError 方法 并在最终转发到自定义实现的方
Android
RXJava
Retrofit2
RxAndroid
Web 响应式编程 - 从 HTTP 客户端的角度来看有哪些优点?
让我们假设控制器生成一些带有延迟的随机数的这两种情况 1 Reactive Spring 5响应式应用 GetMapping randomNumbers public Flux
Spring
RXJava
reactiveprogramming
projectreactor
如何在使用 Retrofit 2 进行单元测试期间创建 Retrofit.Response 对象
在使用 RxJava 和 Retrofit 2 时 我尝试创建单元测试来覆盖我的应用程序何时收到特定响应 我遇到的问题是 在 Retrofit 2 中 我看不到在不使用反射的情况下创建 Retrofit Response 对象的好方法 Te
Android
unittesting
Mockito
Retrofit
RXJava
Spinner 的 RxBindings?
我是新的 android 和 rxjava 我经历过很多使用 rxbindings 监听事件的例子 比如这个 RxView clicks b subscribe new Action1
Android
RXJava
Rxbinding
在 android 中使用 RxJava 和 Retrofit 处理列表
我需要进行几个 api 调用 顺序 异步 其中一些返回列表 我的api接口如下 GET users settings Observable
Android
androidasynctask
Retrofit
RXJava
RxJava 对列表执行操作并返回可观察值
我是 RxJava 特别是 RxJava2 的新手 并且在看似相对简单的操作中遇到了一些麻烦 我需要从数据库获取一些数据 迭代数据 它表示为列表 对每个项目执行操作 将数据包装在另一个对象中并返回 这是我到目前为止所拥有的 mDataMan
Java
Android
RXJava
reactiveprogramming
RxJava2
使用 RXJava 进行缓存处理
我正在尝试使用 rxJava 实现此工作流程 但我确定我是否误用或做错了事情 用户要求登录 如果登录结果在缓存中可用 则 发出 缓存的登录结果 否则 如果一切成功 则实际执行对 Web 服务的请求并缓存结果 如果发生错误 最多重试 3 次
Java
Android
DesignPatterns
reactiveprogramming
RXJava
开始使用 RxJava 和 sqlite
我正在学习 RxJava 并且已经阅读了几篇文章和视频 我对 RxJava 所提供的功能感到非常敬畏 所以我认为目前已经了解了响应式编程的全部内容 Dan Lew 的本教程 http blog danlew net 2014 09 15 g
Android
RXJava
RxJava API 和 Java 9 Flow API 之间的区别
在过去几个主要版本的 Java 的每次迭代中 似乎都有一致的新方法来管理并发任务 在 Java 9 中 我们有Flow API https docs oracle com javase 9 docs api index html java
Java
RXJava
RxJava2
java9
«
1
2
3
4
5
6
...11
»