rx-java - RxJava 引入了 Single<T>。如何将 Observable<T> 转换为 Single<T>？-6ren

rx-java - RxJava 引入了 Single。如何将 Observable 转换为 Single？

转载作者：行者123 更新时间：2023-12-01 23:08:15

25

4

RxJava最近推出Single 。有没有一种方法可以将已经存在的 Observable(几乎是 Single)转换为 Single，而不修改原始 observable 的源？

例如，我有一个 api 服务类，其方法返回 Observable - 本质上是从远程资源获取 User。说我无法修改服务。我想在其他地方消费它，但返回一个单一的。我该怎么做？

多一点背景

RxJava 最近引入了 Single 的概念，它或多或少是一种 Rx 友好的简单回调(即发出一个对象或错误的 Observable)(在此处了解更多信息 - http://reactivex.io/documentation/single.html )

最佳答案

我认为另一个答案已经过时了。您可能应该检查以下方法。

singleOrError:如果源长度超过 1 项，则发出唯一的元素 IndexOutOfBoundsException；如果源为空，则发出 NoSuchElementException。

firstOrError:如果源为空，则发出第一个元素或 NoSuchElementException。

lastOrError:如果源为空，则发出lastelement或NoSuchElementException。

elementAtOrError: 发出第索引元素或 NoSuchElementException。

关于rx-java - RxJava 引入了 Single<T>。如何将 Observable<T> 转换为 Single<T>？，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/36627927/

25

4

0

文章推荐： java - 如何修复不同语言中出现的 setError 消息？

文章推荐： image - 使用 VBA 在文件中插入和保留图像 - Excel 2013

android - Observable.concat(observable,observable) 的奇怪结果
一段时间后，我阅读了有关 RxJava concat 的内容，并决定测试一下我的理解力。但是我遇到了一些我不太理解的行为。问题是，当我连接两个可观察对象时，根据我将它们传递给 Observable.
angular - 类型 Observable> 不可分配给类型 Observable
我正在使用来自数据库服务的数据实现自动完成: @Injectable() export class SchoolService { constructor(private db: AngularF
observable - 创建一个延迟下一个值的 Observable
我正在尝试使用 RxJS 创建一个可观察的对象，它可以执行如图所示的操作。获取一个值并等待一段固定的时间才能获得下一个。下一个将是该周期内发出的最后一个值等等，跳过其余部分。如果等待时间间隔
javascript - 基于 observable，从 observable 对象中选择 observable
我有一个可观察对象和另一个提供的可观察对象改变 key 。我想构建一个在之间切换的可观察对象基于该键的对象中的可观察值。示例: // Choose randomly between "up" or
dart - 我如何@observe 不实现 observe.Observable 的对象在聚合物中
我使用 protobuffers 在我的前端和我的 Dart 服务器之间进行通信。那些对象没有实现 Observable . 我的 Dart 聚合物对象看起来像: @CustomTag('user-
java - 模型类应该扩展 Observable 还是应该是扩展 Observable 的类中的变量 Observable
在 java swing 项目中，我有一个模型类，它保存某个 JPanel 的状态。我需要使这些数据可供 View 使用。我认为有两种选择。有一个扩展 Observable 的类并将模型作为实例变量。
javascript - RxJs - observer.isStopped、observer.observer.isStopped 和 observed.m.isDisposed 之间有什么区别
我想找到一种方法来检测观察者是否已完成使用我使用 Rx.Observable.create 创建的自定义可观察对象，以便自定义可观察对象可以结束它并正确地进行一些清理。因此，我创建了一些测试代码，如
javascript - 将 observable 数组的 observable 转换为 observable 数组
我正在尝试查询数据库。迭代结果列表，并为每一项再执行一个请求。在 rxjs 构建结束时，我有 Observable[]> 。但我需要Observable 。如何做到这一点？ this.caseServ
java - 如何检测 Observable> 中所有包含的 Observable 的完成
我希望我的 api 上有一个方法返回 Observable> 但我希望该方法中的代码知道所有包含的 Observables 是否已完成，以便它可以关闭某些内容。最好的方法是什么？更明确地说，我希望完
java - 使用参数中第一个 Observable 的结果将两个 Observable 与第二个 Observable 组合起来
我有两个方法返回 Observable> firstAPI.getFirstInfo("1", "2"); secondApi.getSecondInfo(resultFirstObservable,
android - 将 Observable> 扁平化为 Observable
我有一个 Observable返回单个 Cursor实例(Observable)。我正在尝试利用 ContentObservable.fromCursor获取 onNext 中每个游标的行回调。我想
java - 将 Observable 与第二个 Observable 结合使用第一个 Observable 的结果
我有两种返回 Observable 的方法: Observable firstObservable(); Observable secondObservable(String value); 对于第一
angular - 嵌套的 Observables : adding an observable as a property of an observable and unwrapping it
我正在尝试创建一个将用户数据作为 Observable 的函数，并使用来自第一个 observable 的数据从查询中添加/合并数据，然后将所有这些数据作为一个 observable 返回，我可以这样
typescript - 将 ECMAScript Observable/Zen Observable 转换为 RXJS Observable
我有一个 spec-compliant ECMAScript Observable ，具体来自 wonka library .我正在尝试将这种类型的 observable 转换为 rxjs 6 obs
javascript - 将 observables 的 observables 数组转换为 observables rxjs 数组
为了简化问题，我在这里使用了数字和字符串。代码: const numbers$:Observable = of([1,2,3]); const strings: string[] = ["a","b"
java - 我如何将来自不同 observable 的 rx.Observable 搜索结果合并到一个 Observable 中？
对于我的 Android 应用程序，我需要一个 Observable 来聚合来自 7 个不同搜索的结果并作为一个集合发出。对于最终发射，我选择了 ListMultimap其中 Content是搜索结
android - Observable 返回类型必须参数化为 Observable 或 Observable
我正在使用改造 2.0.0-beta2 并且调试构建工作正常，但我在使用 Proguard 发布构建时遇到以下错误。这是更新后的 logcat 错误。 11-17 18:23:22.751 1627
typescript - Observable 中的 observer.throw 和 observer.error 有什么区别？
observer.throw(err) 和 observer.error(err) 有什么区别？我正在使用 RxJS 版本“5.0.0-beta.12” var innerObservable =
c# - 接收 : Create a subsequent observable from an observable with a different type (Chaining observers)
我们有一种情况，对服务的方法调用返回一个 IObservable但我们的客户期望 IObservable .将 T1 转换为 T2 很简单。 Rx 中有什么允许这样做的吗？ (即链接观察者) 我知道我
java - 如何将 Observable>> 转换为 Observable>
我陷入了如何将以下可观察类型转换/转换为我的目标类型的困境: 我有可观察的类型: Observable>> 我想将其转换为: Observable> 所以当我订阅它时，它会发出 List不是Obser

首页

博学

6Ren·AI

商城

rx-java - RxJava 引入了 Single。如何将 Observable 转换为 Single？