问题标签 [rx-kotlin2]

不幸的是，我不明白如何检查 Observable。

取决于连接 - 我想从网络或数据库中获取我的数据。

我有一种检查网络连接的方法：

因此，如果这是真的，我想调用我的网络方法：

在另一种情况下，我想调用 DB 方法：

这是我的尝试，但我认为由于可为空的交互器存在问题，但仍然不知道该怎么做。

有人可以帮我吗？

更新

所以问题出在可为空的对象interactor上。

有人可以建议不使用对象的更好方法!!吗interactor？

我正在使用改造和 rxkotlin 调用 apis。但是，当我启动片段时，应用程序在没有任何通知的情况下崩溃，或者在工作室 logcat 中没有显示任何错误消息。这是代码。从这里我调用 apis 接口

这是api接口代码：

这是日志猫：

我有一个场景，我们有一个发射器，它不断发出这样的数据

现在我有一个服务，我在应用程序启动时启动并收听它

我有另一个活动 MainActivity 在启动时调用，我观察到相同的事件。现在的问题是只有服务中的侦听器获取事件并且活动没有接收任何事件。

现在，当我从服务中删除侦听器时，活动开始接收事件。我已经使用运营商共享来共享可观察的，但它似乎不起作用

我刚刚开始使用 RxJava，我正在努力弄清楚如何以正确的方式使用 observables。

在下面我有一个寻呼机，我想在页面滚动时调用一个网络服务，以避免许多无用的调用。

所以我发现“去抖动”运算符是我正在寻找的，但在我的情况下它不起作用并且每次都会调用 Web 服务。

这段代码有什么问题？

enable/disable当代码和名称不为空时，我想要按钮。

我的代码：

但是运行时出错：

日志猫：

io.reactivex.exceptions.OnErrorNotImplementedException：动画只能在 Looper 线程上运行
android.util.AndroidRuntimeException：动画只能在Looper线程上运行

代码崩溃是enable/disable按钮。

我尝试编写一个用于compose()减少样板代码的转换函数。这很简单：

因此，每次我想订阅任何内容ioThread并收听结果时mainThread，只需几行代码：

但不仅有，Observable而且我们还有Single,和。所以每次我想把它们和我的函数结合起来时，我都必须把它转换成新的类型（这是我没想到的）。CompletableMaybeFlowablewithSchedulers()

例如，

所以我的问题是，有没有办法编写上述函数以compose()用于任何类型的Observable( Single, Completable,...) ？或者我们必须编写使用ObservableTransformer, SingleTransformer, .... 的不同函数？

publishSubject 的 onNext 方法正在连续调用（在不均匀的时间，大约在 1 毫秒内）并且要求每 1 秒发出这些项目，并且数据不应该丢失意味着应该发出每个项目。

等等...参见代码结构以供参考：

请帮助，在此先感谢，

我有两个不同的 Observable，它们的行为如下

可观察的一种行为 -> 这将被创建，并且一个 DisposableObserver 将订阅它并对 Observable One 发出的项目做出反应。这将持续运行，直到应用程序关闭。

可观察的两个行为 -> 这将在不同的时间被创建并订阅到不同的观察者，并且在订阅之后，这应该根据订阅可观察的两个后观察者发出的值发出值。一旦工作完成 Observable 两个订阅将被处理，但 Observable 一个应该继续。

如何使第二个 Observable 基于 Observable 发出的值发出值并在完成后处理它？

如何在 RxJava2/RxKotlin2 中实现Observable.concatEagerDelayError或等效项？

有 ：

• Observable.concatEager
• Observable.concatDelayError

但不是 ：

• Observable.concatEagerDelayError

是）我有的 ：

我想要相同的行为，但渴望 selectAll() 和 getAll() 因为没有理由等待从 db 启动网络调用。

对于 kotlin android 中的单元测试，我一直在使用模拟框架 MockK。使用过 RxKotlin。我使用 Completable observable 来通知 ViewModel API 的状态。根据 Completable，状态将在 ViewModel 中更新为成功或失败。我的问题是如何使用 MockK 模拟 RxKotlin 的可完成观察，并根据模拟的可完成检查单元测试函数中的状态。

片段

未知

如何使用可完成的返回模拟函数调用订阅 testobserver