问题标签 [rx-kotlin2]

我有一个场景，我必须异步获取一些字符串。我想创建一个方法，当成功获取此值然后将其提供给侦听器时，我可以在其中收听。现在，这可以通过多种方式轻松完成，包括回调侦听器或 lambda。

但是我应该使用什么来使对该方法的所有后续调用也返回字符串 - 无需再次获取它，因为它已经被获取了一次。因此，侦听器仍处于连接状态但在可用时立即提供值的解决方案。我知道如何通过老式的回调监听器来做到这一点，该值被存储在其中，然后对于后续调用，它可以通过回调立即返回。

但是有没有更紧凑/更复杂的方法来做到这一点，比如说通过 Rx？

谢谢。

我有以下类，它公开一个 Single 来获取 ID。

这用于在该类的 init 上获取 ID，以后其他人也可以使用它来获取 ID。

从我订阅此单曲的任何其他地方，我都能获得 ID。但是这里的init方法中，这个方法似乎并没有启动并获取ID。

有人可以帮我理解我所缺少的吗？谢谢

}

我是使用 Kotlin 进行 Android 开发的新手，我正在努力寻找有关如何使用当前最佳实践创建简单 GET 和 POST 请求的任何有用文档。我来自 Angular 开发，我们使用 RxJS 进行响应式开发。

通常我会创建一个服务文件来保存我所有的请求函数，然后我会在任何组件中使用这个服务并订阅 observable。

您将如何在 Android 中执行此操作？是否有一个很好的例子来说明必须创建的东西。乍一看，一切看起来都如此复杂和过度设计

我从一个对象获得了两次回调事件，有时三次，但我只需要收集一个将是最新的对象。RX kotlin 可以吗？

我有一个执行网络请求并返回带有可变数据类列表的 Observable 的方法。有时此方法会因 403 错误而失败。我需要调用 YouTubeClient.getApiKey() 方法来获取新的 Api 密钥并重复对网络的请求。怎么做？我阅读了很多类似的主题，但没有找到可行的决定。

实用方法的这段代码，当我尝试调用 retryWhen() 方法时

Main 方法在下面调用自身内部的实用程序方法

Observable 发出交易对象。如何将每个发射的操作变成一个结果对象？

交易（交易类型：字符串，利润：BigDecimal）结果（totalProfit：BigDecimal）

例子：

我有一个 Kotlin 中重复出现的元素列表，比如：

我想按它们的值以及它们出现的次数对它们进行分组，因此输出将是成对的：

我已经解决了在 Kotlin 中使用的问题，如下所示：

我想在 RxKotlin 中编写相同的代码进行学习并尝试了以下但不知道如何应用map/flatMap来实现结果。

I'm trying to create a BLE service that will scan for devices and using rxKotlin create an observable that will allow another class to observe when a device is found. I'm confused on how to create the observable that will allow another class to subscribe and tutorials are all over the place. Can someone give me a pointer on how to do so or a good tutorial.

Bluetoothservice class callback where devices are discovered

Solution

Was able to find the solution after reading user4097210's reply. Just had to change the found device to

and then call the next method in the callback

我正在尝试使用以下代码将多个可观察对象合并为一个：

它们都有一个类型Observable<MyItem>，除了obs4is Observable<List<MyItem>>，所以我想在结果列表中用.flatMap { Observable.fromIterable(it) }. 这里的问题是如果obs4发出一个空列表，那么结果链永远不会发出，因为combineLatest等待所有源发出第一个项目。是否有任何运算符会在每个源的每次更改时发出忽略空源的信息？

想象一下有两个BehaviourSubject字符串：

我是否更新了每个喜欢的位置

然后我有一个枚举类

在 Observable 中使用：

我结合以上Subjects和Observables通过combineLatest()：

现在我想subjectLocationC根据上面的例子扩展第三个位置主题。但我即将扩展 combineLatest：

IDE抱怨

类型不匹配。

必需：(TypeVariable(T1), TypeVariable(T2), TypeVariable(T3)) → TypeVariable(R)

发现：可观察的

和

无法推断此参数的类型。请明确指定。

根据Observables实施情况，除其他外

和

但两者之间什么都没有？！我想我需要

还是我错了？也许有解决方法吗？我错过了什么？