java - RxJava 结合 Observables

In lại Tác giả: Walker 123 更新时间：2023-11-29 04:32:15 28 4

...
compoundObservable = compoundObservable.mergeWith(firstObservable);
...
compoundObservable = compoundObservable.mergeWith(secondObservable);
...

PublishSubject

28 4 0

• android - 如何使用 RXJava 调用的响应结果作为另一个 RXJava 函数内 if 语句的条件？

  我正在进行 2 个 RX 调用，这些调用相互嵌套且相互依赖。服务器存在问题(由于各种原因目前无法解决)，该问题在第二个嵌套调用中返回错误。 在这个问题得到解决之前，我需要确保如果第二次调用返回错误，则

• android - RxJava 1 和 RxJava 2 在同一个项目中

  这个问题在这里已经有了答案: How to resolve Duplicate files copied in APK META-INF/rxjava.properties (8 个答案) 关闭 5

• java - 从 RxJava 1 到 RxJava 2

  我正在尝试将此 RxJava1 代码转换为 RxJava2 public static Observable listFolder(Path dir, String glob) { retur

• java - RxJava 和 RxJava 2 可以共存于同一个 Android 项目中吗？

  这个问题在这里已经有了答案: RxJava 1 and RxJava 2 in the same project [duplicate] (1 个回答) How to resolve Duplica

• android - 如何使用 RxJava 将数据从数据库加载到 RecyclerView？ (MVP + RxJava + SQLite)

  有显示项目的RecyclerViewAdapter(该项目已经映射到数据库中)。 RecyclerViewAdapter 包含对 Presenter 的引用以加载项目。它还包含带有项目 ID 的 Ar

• android - Realm + RxJava + Android : Saving Realm object using RxJava in Android

  我想弄清楚如何在 Android 中使用 RxJava 将 Realm 对象保存在 Realm 中。到目前为止，结合所有这些的所有示例都是如何从 Realm 读取数据的。我想在 android 中使用

• android - java.net.UnknownHostException 无法使用 RxJava 转换为 retrofit2.adapter.rxjava.HttpException

  我在日志中收到此错误: Caused by java.lang.ClassCastException: java.net.UnknownHostException cannot be cast to

• kotlin - RxJava 如何将 Rxjava 中的 Single 转换为 Retrofit 中的 Call 或相反的转换

  我有一个 API 服务类，其方法返回 Retrofit 提供的调用。 最近，Rx2Java 引入了 Single，所以我想将 Call 更改为 Single，但我不想更改逻辑。 例如 : 类接口(in

• kotlin - Rxjava - 如何获取当前和上一个项目？

  如何使用运算符让我始终获得以前和当前的值？如果可能的话，我想避免在管道外创建状态。 - time -> 1 2 3 4 | | | | Op

• android rxjava 重复请求

  我正在努力实现以下目标。我加载了一个对象列表，我想获取稍后放入列表中的值。 首先，我使用 flatmap 将所有值收集到一个数组中(按山顺序)，然后当一切完成后，我填充一个适配器。 我无法做的是每

• operators - RxJava 超时而不发出错误？

  是否可以选择使用 timeout 的变体不发射 Throwable ? 我要 complete事件发出。 最佳答案 您不需要使用 onErrorResumeNext 映射错误。您可以使用以下方法提供备

• c# - 等价于 RxJava

  我们可以在 C# Rx 中异步执行一些代码，如下所示，使用 Observable.Start()。我想知道 RxJava 中的等价物是什么。 void Main() { AddTwoNum

• android - RxJava 运算符结合两个可观察对象并在第一个可观察对象发出时立即发出

  问题:我有一个用户可以输入查询字符串的功能，我制作了 2 个可观察对象，一个用于查询我的本地数据库，另一个用于从 API 获取结果。这两个操作必须并行运行。我需要尽快显示来自数据库的结果，当 API

• mvvm - RxJava - 主题中的错误处理

  我正在尝试在 MVVM 中实现 ViewModel，将可观察对象作为“输入流”提供，将观察者作为“输出流”提供以供 View 绑定(bind)。 如果 getUser() 调用成功，下面的代码似乎可以

• operators - RxJava 在函数中返回订阅值

  出于某种原因，我有时想使用 RxOperators 而不是普通的 java 方式来转换数据结构，因为它越来越干净。例如: Observable.from(listOfStrings) .filter(

• java - RxJava 中的超时

  我是 RxJava 新手，我需要以异步方式使用 Observable 功能。 我还需要使用超时:在我的示例中，我希望每个进程在 1 秒或更短的时间内结束。 这是我现在所做的: public stati

• kotlin - RxJava Single最小执行时间

  我正在尝试在网络请求期间在UI中显示进度条至少3秒钟。 此答案中描述的相同方法似乎不适用于Single。 RxJava Observable minimum execution time Single

• java - rxjava 间隔与另一个可观察值相结合

  我有一个可观察的(很热)，它通过系统进程执行操作，并且我希望也运行一个间隔，直到该进程可观察达到 onComplete。 我看到区间运算符:http://reactivex.io/documentat

• java - RxJava 和长时间运行的监听器

  好吧，我是 RxJava2 的新手(嗯，我也不了解 RxJava)，并且正在尝试使用 RxJava2 和 MVP 结构开发 Android 应用程序。 在该应用程序中，我正在对使用监听器的库进行异步调

• kotlin - RxJava:如何拆分单

  如何将单个流拆分为单独的单个流，这样就可以执行以下操作而无需两次计算getUserId()？ // getUserId() returns Single getUserId().flatMap { g